org.apache.reef.vortex.driver

Interface VortexFutureDelegate<TOutput>

All Known Implementing Classes:

VortexAggregateFuture, VortexFuture

public interface VortexFutureDelegate<TOutput>

Exposes functions to be called by the VortexMaster to note that a list of Tasklets associated with a Future has completed.

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregationCompleted(List<Integer> taskletIds, TOutput result) The list of aggregated Tasklets associated with the Future that have completed with a result.
void	aggregationThrewException(List<Integer> taskletIds, Exception exception) The list of Tasklets associated with the Future that have thrown an Exception.
void	cancelled(int taskletId) A Tasklet associated with the Future has been cancelled.
void	completed(int taskletId, TOutput result) A Tasklet associated with the future has completed with a result.
void	threwException(int taskletId, Exception exception) A Tasklet associated with the Future has thrown an Exception.

Method Detail

completed

void completed(int taskletId,
             TOutput result)

A Tasklet associated with the future has completed with a result.

aggregationCompleted

void aggregationCompleted(List<Integer> taskletIds,
                        TOutput result)

The list of aggregated Tasklets associated with the Future that have completed with a result.

threwException

void threwException(int taskletId,
                  Exception exception)

A Tasklet associated with the Future has thrown an Exception.

aggregationThrewException

void aggregationThrewException(List<Integer> taskletIds,
                             Exception exception)

The list of Tasklets associated with the Future that have thrown an Exception.

cancelled

void cancelled(int taskletId)

A Tasklet associated with the Future has been cancelled.