Uses of Class
org.apache.flink.table.runtime.operators.process.PassThroughCollectorBase
-
Packages that use PassThroughCollectorBase Package Description org.apache.flink.table.runtime.generated org.apache.flink.table.runtime.operators.process -
-
Uses of PassThroughCollectorBase in org.apache.flink.table.runtime.generated
Fields in org.apache.flink.table.runtime.generated declared as PassThroughCollectorBase Modifier and Type Field Description protected PassThroughCollectorBaseProcessTableRunner. evalCollectorMethods in org.apache.flink.table.runtime.generated with parameters of type PassThroughCollectorBase Modifier and Type Method Description voidProcessTableRunner. initialize(org.apache.flink.api.common.state.State[] stateHandles, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, boolean emitRowtime, AbstractProcessTableOperator.RunnerContext runnerContext, AbstractProcessTableOperator.RunnerOnTimerContext runnerOnTimerContext, PassThroughCollectorBase evalCollector, PassAllCollector onTimerCollector) -
Uses of PassThroughCollectorBase in org.apache.flink.table.runtime.operators.process
Subclasses of PassThroughCollectorBase in org.apache.flink.table.runtime.operators.process Modifier and Type Class Description classPassAllCollectorForwards all columns of the given row.classPassPartitionKeysCollectorForwards partition keys of the given input's row.
-