Package org.apache.wayang.core.function
Interface ExecutionContext
-
- All Known Implementing Classes:
FlinkExecutionContext
,JavaExecutionContext
,SparkExecutionContext
public interface ExecutionContext
While 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.int
getCurrentIteration()
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-1
if there is no surroundingLoopSubplan
-
-