org.apache.flink.api.common.functions

Interface IterationRuntimeContext

All Superinterfaces:

RuntimeContext

@Public
public interface IterationRuntimeContext
extends RuntimeContext

Method Summary

Modifier and Type	Method and Description
<T extends Aggregator<?>> T	getIterationAggregator(String name)
<T extends Value> T	getPreviousIterationAggregate(String name)
int	getSuperstepNumber() Gets the number of the current superstep.

Methods inherited from interface org.apache.flink.api.common.functions.RuntimeContext

addAccumulator, getAccumulator, getAllAccumulators, getAttemptNumber, getBroadcastVariable, getBroadcastVariableWithInitializer, getDistributedCache, getDoubleCounter, getExecutionConfig, getHistogram, getIndexOfThisSubtask, getIntCounter, getKeyValueState, getKeyValueState, getListState, getLongCounter, getNumberOfParallelSubtasks, getReducingState, getState, getTaskName, getTaskNameWithSubtasks, getUserCodeClassLoader

Method Detail

getSuperstepNumber

int getSuperstepNumber()

Gets the number of the current superstep. Superstep numbers start at 1.

Returns:

The number of the current superstep.

getIterationAggregator

@PublicEvolving
<T extends Aggregator<?>> T getIterationAggregator(String name)

getPreviousIterationAggregate

<T extends Value> T getPreviousIterationAggregate(String name)