org.apache.reef.vortex.api

Interface VortexAggregateFunction<TOutput>

Type Parameters:

TOutput - output type of the aggregation function and the functions to-be-aggregated.

All Known Implementing Classes:

AdditionAggregateFunction

public interface VortexAggregateFunction<TOutput>

Typed user function for Local Aggregation. Implement your functions using this interface.

Method Summary

Methods

Modifier and Type	Method and Description
TOutput	call(List<TOutput> taskletOutputs) Runs a custom local aggregation function on Tasklets assigned to a VortexWorker.

Method Detail

call

TOutput call(List<TOutput> taskletOutputs)
             throws VortexAggregateException

Runs a custom local aggregation function on Tasklets assigned to a VortexWorker.

Parameters:

taskletOutputs - the list of outputs from Tasklets on a Worker.

Returns:

the aggregated output of Tasklets.

Throws:

Exception

VortexAggregateException