Uses of Class
org.apache.flink.table.runtime.operators.process.RuntimeChangelogMode
-
Packages that use RuntimeChangelogMode Package Description org.apache.flink.table.runtime.operators.process -
-
Uses of RuntimeChangelogMode in org.apache.flink.table.runtime.operators.process
Methods in org.apache.flink.table.runtime.operators.process that return RuntimeChangelogMode Modifier and Type Method Description static RuntimeChangelogModeRuntimeChangelogMode. serialize(org.apache.flink.table.connector.ChangelogMode mode)Constructors in org.apache.flink.table.runtime.operators.process with parameters of type RuntimeChangelogMode 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)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)RuntimeTableSemantics(String argName, int inputIndex, org.apache.flink.table.types.DataType dataType, int[] partitionByColumns, RuntimeChangelogMode consumedChangelogMode, boolean passColumnsThrough, boolean hasSetSemantics, int timeColumn)
-