Package org.apache.flink.table.runtime.operators.process

Class AbstractProcessTableOperator.RunnerContext

java.lang.Object

org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator.RunnerContext

All Implemented Interfaces:

org.apache.flink.table.functions.ProcessTableFunction.Context

Direct Known Subclasses:

AbstractProcessTableOperator.RunnerOnTimerContext

Enclosing class:

AbstractProcessTableOperator

@Internal
public class AbstractProcessTableOperator.RunnerContext
extends Object
implements org.apache.flink.table.functions.ProcessTableFunction.Context

Implementation of ProcessTableFunction.Context.

Method Summary

Modifier and Type	Method	Description
void	clearAll()
void	clearAllState()
void	clearAllTimers()
void	clearState(String stateName)
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
org.apache.flink.api.common.state.StateDescriptor<?,?>	getStateDescriptor(String stateName)
org.apache.flink.table.functions.TableSemantics	tableSemanticsFor(String argName)
<TimeType> org.apache.flink.table.functions.ProcessTableFunction.TimeContext<TimeType>	timeContext(Class<TimeType> conversionClass)

Methods inherited from class java.lang.Object

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

Method Detail

timeContext

public <TimeType> org.apache.flink.table.functions.ProcessTableFunction.TimeContext<TimeType> timeContext(Class<TimeType> conversionClass)

Specified by:

timeContext in interface org.apache.flink.table.functions.ProcessTableFunction.Context

tableSemanticsFor

public org.apache.flink.table.functions.TableSemantics tableSemanticsFor(String argName)

Specified by:

tableSemanticsFor in interface org.apache.flink.table.functions.ProcessTableFunction.Context

clearState

public void clearState(String stateName)

Specified by:

clearState in interface org.apache.flink.table.functions.ProcessTableFunction.Context

clearAllState

public void clearAllState()

Specified by:

clearAllState in interface org.apache.flink.table.functions.ProcessTableFunction.Context

clearAllTimers

public void clearAllTimers()

Specified by:

clearAllTimers in interface org.apache.flink.table.functions.ProcessTableFunction.Context

clearAll

public void clearAll()

Specified by:

clearAll in interface org.apache.flink.table.functions.ProcessTableFunction.Context

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode()

Specified by:

getChangelogMode in interface org.apache.flink.table.functions.ProcessTableFunction.Context

getStateDescriptor

@VisibleForTesting
public org.apache.flink.api.common.state.StateDescriptor<?,?> getStateDescriptor(String stateName)