org.apache.reef.vortex.api

Class AggregateResult<TInput,TOutput>

java.lang.Object

org.apache.reef.vortex.api.AggregateResult<TInput,TOutput>

public final class AggregateResult<TInput,TOutput>
extends Object

The result of an aggregate. Registered to callbacks for VortexAggregateFuture.

Method Summary

Modifier and Type	Method and Description
List<TInput>	getAggregatedInputs()
TOutput	getAggregateResult()
Optional<Exception>	getException() If an aggregation fails, VortexAggregateException will be thrown, otherwise the Exception that caused the Tasklet to fail will be thrown directly.

Methods inherited from class java.lang.Object

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

Method Detail

getAggregateResult

public TOutput getAggregateResult()
                           throws VortexAggregateException

Returns:

the output of an aggregation, throws the Exception if a Tasklet or an aggregation fails. If an aggregation fails, VortexAggregateException will be thrown, otherwise the Exception that caused the Tasklet to fail will be thrown directly.

Throws:

Exception - the Exception that caused the Tasklet or aggregation failure.

VortexAggregateException

getAggregatedInputs

public List<TInput> getAggregatedInputs()

Returns:

the associated inputs of an aggregation

getException

public Optional<Exception> getException()

If an aggregation fails, VortexAggregateException will be thrown, otherwise the Exception that caused the Tasklet to fail will be thrown directly.

Returns:

the Exception that caused the Tasklet or aggregation failure, if any.