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 certain Platform, allows access to some information of the context in which the function is being executed.

  • Method Summary

    Modifier and Type
    Method
    Description
    <T> Collection<T>
    getBroadcast(String name)
    Accesses a broadcast.
    int
    getCurrentIteration()
    If this instance reflects the state of execution inside of a LoopSubplan, then retrieve the number of the current iteration.

  • Method Details

    • getBroadcast

      <T> Collection<T> getBroadcast(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 a LoopSubplan, then retrieve the number of the current iteration.
      Returns:
      the iteration number, start at 0, or -1 if there is no surrounding LoopSubplan