Package org.apache.wayang.java.execution

Class JavaExecutionContext

java.lang.Object

org.apache.wayang.java.execution.JavaExecutionContext

All Implemented Interfaces:

ExecutionContext

public class JavaExecutionContext
extends Object
implements ExecutionContext

ExecutionContext implementation for the JavaPlatform.

Constructor Summary

Constructors

Constructor	Description
JavaExecutionContext(JavaExecutionOperator operator, ChannelInstance[] inputs, int iterationNumber)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JavaExecutionContext

public JavaExecutionContext(JavaExecutionOperator operator,
 ChannelInstance[] inputs,
 int iterationNumber)

Method Details

getBroadcast

public <T> Collection<T> getBroadcast(String name)

Description copied from interface: ExecutionContext

Accesses a broadcast.

Specified by:

getBroadcast in interface ExecutionContext

Type Parameters:

T - type of the broadcast

Parameters:

name - name of the broadcast

Returns:

the broadcast

getCurrentIteration

public int getCurrentIteration()

Description copied from interface: ExecutionContext

If this instance reflects the state of execution inside of a LoopSubplan, then retrieve the number of the current iteration.

Specified by:

getCurrentIteration in interface ExecutionContext

Returns:

the iteration number, start at 0, or -1 if there is no surrounding LoopSubplan