Package org.apache.wayang.core.function
Interface ExecutionContext
-
- All Known Implementing Classes:
FlinkExecutionContext,JavaExecutionContext,SparkExecutionContext
public interface ExecutionContextWhile a function is executed on a certainPlatform, allows access to some information of the context in which the function is being executed.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> java.util.Collection<T>getBroadcast(java.lang.String name)Accesses a broadcast.intgetCurrentIteration()If this instance reflects the state of execution inside of aLoopSubplan, then retrieve the number of the current iteration.
-
-
-
Method Detail
-
getBroadcast
<T> java.util.Collection<T> getBroadcast(java.lang.String name)
Accesses a broadcast.- Type Parameters:
T- type of the broadcast- Parameters:
name- name of the broadcast- Returns:
- the broadcast
-
getCurrentIteration
int getCurrentIteration()
If this instance reflects the state of execution inside of aLoopSubplan, then retrieve the number of the current iteration.- Returns:
- the iteration number, start at
0, or-1if there is no surroundingLoopSubplan
-
-