Package org.apache.flink.api.common.functions

Interface IterationRuntimeContext

All Superinterfaces:

RuntimeContext

@Public
public interface IterationRuntimeContext
extends RuntimeContext

A specialization of the RuntimeContext available in iterative computations of the DataSet API.

Method Summary

Modifier and Type	Method	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, createSerializer, getAccumulator, getAggregatingState, getAttemptNumber, getBroadcastVariable, getBroadcastVariableWithInitializer, getDistributedCache, getDoubleCounter, getExecutionConfig, getExternalResourceInfos, getGlobalJobParameters, getHistogram, getIndexOfThisSubtask, getIntCounter, getJobId, getJobInfo, getListState, getLongCounter, getMapState, getMaxNumberOfParallelSubtasks, getMetricGroup, getNumberOfParallelSubtasks, getReducingState, getState, getTaskInfo, getTaskName, getTaskNameWithSubtasks, getUserCodeClassLoader, hasBroadcastVariable, isObjectReuseEnabled, registerUserCodeClassLoaderReleaseHookIfAbsent

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)