Uses of Class
org.apache.flink.table.runtime.operators.python.utils.StreamRecordRowDataWrappingCollector
-
-
Uses of StreamRecordRowDataWrappingCollector in org.apache.flink.table.runtime.operators.python
Fields in org.apache.flink.table.runtime.operators.python declared as StreamRecordRowDataWrappingCollector Modifier and Type Field Description protected StreamRecordRowDataWrappingCollectorAbstractEmbeddedStatelessFunctionOperator. rowDataWrapperThe collector used to collect records. -
Uses of StreamRecordRowDataWrappingCollector in org.apache.flink.table.runtime.operators.python.aggregate
Fields in org.apache.flink.table.runtime.operators.python.aggregate declared as StreamRecordRowDataWrappingCollector Modifier and Type Field Description protected StreamRecordRowDataWrappingCollectorAbstractPythonStreamAggregateOperator. rowDataWrapperThe collector used to collect records. -
Uses of StreamRecordRowDataWrappingCollector in org.apache.flink.table.runtime.operators.python.aggregate.arrow
Fields in org.apache.flink.table.runtime.operators.python.aggregate.arrow declared as StreamRecordRowDataWrappingCollector Modifier and Type Field Description protected StreamRecordRowDataWrappingCollectorAbstractArrowPythonAggregateFunctionOperator. rowDataWrapperThe collector used to collect records. -
Uses of StreamRecordRowDataWrappingCollector in org.apache.flink.table.runtime.operators.python.scalar
Fields in org.apache.flink.table.runtime.operators.python.scalar declared as StreamRecordRowDataWrappingCollector Modifier and Type Field Description protected StreamRecordRowDataWrappingCollectorAbstractPythonScalarFunctionOperator. rowDataWrapperThe collector used to collect records.
-