@Public public interface IterationRuntimeContext extends RuntimeContext
RuntimeContext
available in iterative computations of the DataSet
API.Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
getIterationAggregator(String name) |
<T extends Value> |
getPreviousIterationAggregate(String name) |
int |
getSuperstepNumber()
Gets the number of the current superstep.
|
addAccumulator, getAccumulator, getAggregatingState, getAttemptNumber, getBroadcastVariable, getBroadcastVariableWithInitializer, getDistributedCache, getDoubleCounter, getExecutionConfig, getExternalResourceInfos, getHistogram, getIndexOfThisSubtask, getIntCounter, getJobId, getListState, getLongCounter, getMapState, getMaxNumberOfParallelSubtasks, getMetricGroup, getNumberOfParallelSubtasks, getReducingState, getState, getTaskName, getTaskNameWithSubtasks, getUserCodeClassLoader, hasBroadcastVariable, registerUserCodeClassLoaderReleaseHookIfAbsent
int getSuperstepNumber()
@PublicEvolving <T extends Aggregator<?>> T getIterationAggregator(String name)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.