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

Class RuntimeTableSemantics

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.table.functions.TableSemantics

public class RuntimeTableSemantics
extends Object
implements org.apache.flink.table.functions.TableSemantics, Serializable

Serializable representation of TableSemantics that will serve ProcessTableFunction.Context.tableSemanticsFor(String) during runtime.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RuntimeTableSemantics(String argName, int inputIndex, org.apache.flink.table.types.DataType dataType, int[] partitionByColumns, RuntimeChangelogMode consumedChangelogMode, boolean passColumnsThrough, boolean hasSetSemantics, int timeColumn)

Method Summary

Modifier and Type	Method	Description
Optional<org.apache.flink.table.connector.ChangelogMode>	changelogMode()
org.apache.flink.table.types.DataType	dataType()
String	getArgName()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
int	getInputIndex()
boolean	hasSetSemantics()
int[]	orderByColumns()
int[]	partitionByColumns()
boolean	passColumnsThrough()
int	timeColumn()

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeTableSemantics

public RuntimeTableSemantics(String argName,
                             int inputIndex,
                             org.apache.flink.table.types.DataType dataType,
                             int[] partitionByColumns,
                             RuntimeChangelogMode consumedChangelogMode,
                             boolean passColumnsThrough,
                             boolean hasSetSemantics,
                             int timeColumn)

Method Detail

getArgName

public String getArgName()

getInputIndex

public int getInputIndex()

passColumnsThrough

public boolean passColumnsThrough()

hasSetSemantics

public boolean hasSetSemantics()

getChangelogMode

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

dataType

public org.apache.flink.table.types.DataType dataType()

Specified by:

dataType in interface org.apache.flink.table.functions.TableSemantics

partitionByColumns

public int[] partitionByColumns()

Specified by:

partitionByColumns in interface org.apache.flink.table.functions.TableSemantics

orderByColumns

public int[] orderByColumns()

Specified by:

orderByColumns in interface org.apache.flink.table.functions.TableSemantics

timeColumn

public int timeColumn()

Specified by:

timeColumn in interface org.apache.flink.table.functions.TableSemantics

changelogMode

public Optional<org.apache.flink.table.connector.ChangelogMode> changelogMode()

Specified by:

changelogMode in interface org.apache.flink.table.functions.TableSemantics