Uses of Class
org.apache.flink.table.runtime.operators.process.RuntimeTableSemantics
-
Packages that use RuntimeTableSemantics Package Description org.apache.flink.table.runtime.operators.process -
-
Uses of RuntimeTableSemantics in org.apache.flink.table.runtime.operators.process
Fields in org.apache.flink.table.runtime.operators.process with type parameters of type RuntimeTableSemantics Modifier and Type Field Description protected List<RuntimeTableSemantics>AbstractProcessTableOperator. tableSemanticsConstructor parameters in org.apache.flink.table.runtime.operators.process with type arguments of type RuntimeTableSemantics Constructor Description AbstractProcessTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)PassPartitionKeysCollector(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>> output, org.apache.flink.table.connector.ChangelogMode changelogMode, List<RuntimeTableSemantics> tableSemantics)ProcessRowTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)ProcessSetTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)ProcessTableOperatorFactory(List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, GeneratedProcessTableRunner generatedProcessTableRunner, GeneratedHashFunction[] generatedStateHashCode, GeneratedRecordEqualiser[] generatedStateEquals, RuntimeChangelogMode producedChangelogMode)
-