org.apache.reef.vortex.common

Interface VortexFutureDelegate

All Known Implementing Classes:

VortexAggregateFuture, VortexFuture

public interface VortexFutureDelegate

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, byte[] serializedResult) 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, byte[] serializedResult) 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,
             byte[] serializedResult)

A Tasklet associated with the future has completed with a result. The result should be decoded as in VortexFuture.completed(int, byte[]).

aggregationCompleted

void aggregationCompleted(List<Integer> taskletIds,
                        byte[] serializedResult)

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.