Class AbstractProcessTableOperator.RunnerOnTimerContext
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator.RunnerContext
-
- org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator.RunnerOnTimerContext
-
- All Implemented Interfaces:
org.apache.flink.table.functions.ProcessTableFunction.Context,org.apache.flink.table.functions.ProcessTableFunction.OnTimerContext
- Enclosing class:
- AbstractProcessTableOperator
@Internal public class AbstractProcessTableOperator.RunnerOnTimerContext extends AbstractProcessTableOperator.RunnerContext implements org.apache.flink.table.functions.ProcessTableFunction.OnTimerContext
Implementation ofProcessTableFunction.OnTimerContext.
-
-
Constructor Summary
Constructors Constructor Description RunnerOnTimerContext()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringcurrentTimer()-
Methods inherited from class org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator.RunnerContext
clearAll, clearAllState, clearAllTimers, clearState, getChangelogMode, getStateDescriptor, tableSemanticsFor, timeContext
-
-
-
-
Method Detail
-
currentTimer
@Nullable public String currentTimer()
- Specified by:
currentTimerin interfaceorg.apache.flink.table.functions.ProcessTableFunction.OnTimerContext
-
-