org.apache.reef.vortex.examples.sumones

Class AdditionAggregateFunction

java.lang.Object

org.apache.reef.vortex.examples.sumones.AdditionAggregateFunction

All Implemented Interfaces:

Serializable, VortexAggregateFunction<Integer>

public final class AdditionAggregateFunction
extends Object
implements VortexAggregateFunction<Integer>

Aggregates and sums the outputs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AdditionAggregateFunction()

Method Summary

Methods

Modifier and Type	Method and Description
Integer	call(List<Integer> taskletOutputs) Runs a custom local aggregation function on Tasklets assigned to a VortexWorker.
Codec<Integer>	getOutputCodec() Users must define codec for the AggregationOutput.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdditionAggregateFunction

public AdditionAggregateFunction()

Method Detail

call

public Integer call(List<Integer> taskletOutputs)
             throws VortexAggregateException

Description copied from interface: VortexAggregateFunction

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

Specified by:

call in interface VortexAggregateFunction<Integer>

Parameters:

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

Returns:

the aggregated output of Tasklets.

Throws:

VortexAggregateException

getOutputCodec

public Codec<Integer> getOutputCodec()

Description copied from interface: VortexAggregateFunction

Users must define codec for the AggregationOutput. VoidCodec can be used if the aggregation output is empty, and SerializableCodec can be used for (Serializable aggregation output. Custom aggregation output Codec can also be supplied.

Specified by:

getOutputCodec in interface VortexAggregateFunction<Integer>

Returns:

Codec used to serialize/deserialize the output.