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 Description ExecutionContextImpl(AbstractStreamOperator<?> operator, RuntimeContext runtimeContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RowData
currentKey()
RuntimeContext
getRuntimeContext()
void
setCurrentKey(RowData key)
Sets current key.
-
-
-
Constructor Detail
-
ExecutionContextImpl
public ExecutionContextImpl(AbstractStreamOperator<?> operator, RuntimeContext runtimeContext)
-
-
Method Detail
-
currentKey
public RowData currentKey()
- Specified by:
currentKey
in interfaceExecutionContext
- 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 interfaceExecutionContext
-
getRuntimeContext
public RuntimeContext getRuntimeContext()
- Specified by:
getRuntimeContext
in interfaceExecutionContext
-
-