org.apache.flink.table.runtime.context

Class ExecutionContextImpl

java.lang.Object

org.apache.flink.table.runtime.context.ExecutionContextImpl

All Implemented Interfaces:

ExecutionContext

public final class ExecutionContextImpl
extends Object
implements ExecutionContext

Implementation of ExecutionContext.

Constructor Summary

Constructors

Constructor and Description
ExecutionContextImpl(AbstractStreamOperator<?> operator, RuntimeContext runtimeContext)

Method Summary

Modifier and Type	Method and Description
RowData	currentKey()
RuntimeContext	getRuntimeContext()
void	setCurrentKey(RowData key) Sets current key.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionContextImpl

public ExecutionContextImpl(AbstractStreamOperator<?> operator,
                            RuntimeContext runtimeContext)

Method Detail

currentKey

public RowData currentKey()

Specified by:

currentKey in interface ExecutionContext

Returns:

key of the current processed element.

setCurrentKey

public void setCurrentKey(RowData key)

Description copied from interface: ExecutionContext

Sets current key.

Specified by:

setCurrentKey in interface ExecutionContext

getRuntimeContext

public RuntimeContext getRuntimeContext()

Specified by:

getRuntimeContext in interface ExecutionContext