Package org.apache.wayang.flink.execution

Class FlinkExecutionContext

java.lang.Object

org.apache.wayang.flink.execution.FlinkExecutionContext

All Implemented Interfaces:

Serializable, ExecutionContext

public class FlinkExecutionContext
extends Object
implements ExecutionContext, Serializable

ExecutionContext implementation for the FlinkPlatform.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkExecutionContext(FlinkExecutionOperator operator, ChannelInstance[] inputs, int iterationNumber)

Method Summary

Modifier and Type	Method	Description
<Type> Collection<Type>	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.
void	setRichFunction(org.apache.flink.api.common.functions.RichFunction richFunction)

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkExecutionContext

public FlinkExecutionContext(FlinkExecutionOperator operator,
 ChannelInstance[] inputs,
 int iterationNumber)

Method Details

getBroadcast

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

Description copied from interface: ExecutionContext

Accesses a broadcast.

Specified by:

getBroadcast in interface ExecutionContext

Type Parameters:

Type - type of the broadcast

Parameters:

name - name of the broadcast

Returns:

the broadcast

setRichFunction

public void setRichFunction(org.apache.flink.api.common.functions.RichFunction richFunction)

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