Uses of Class
org.apache.flink.table.runtime.util.StreamRecordCollector

Packages that use StreamRecordCollector

Package	Description
org.apache.flink.table.runtime.operators.hive.script
org.apache.flink.table.runtime.operators.join

Uses of StreamRecordCollector in org.apache.flink.table.runtime.operators.hive.script

Constructors in org.apache.flink.table.runtime.operators.hive.script with parameters of type StreamRecordCollector

Constructor and Description
HiveScriptTransformOutReadThread(org.apache.hadoop.hive.ql.exec.RecordReader recordReader, LogicalType outputType, org.apache.hadoop.hive.serde2.AbstractSerDe outSerDe, org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector structObjectInspector, StreamRecordCollector<RowData> collector)

Uses of StreamRecordCollector in org.apache.flink.table.runtime.operators.join

Methods in org.apache.flink.table.runtime.operators.join with parameters of type StreamRecordCollector

Modifier and Type	Method and Description
void	SortMergeJoinFunction.open(boolean adaptiveHashJoin, StreamTask<?,?> taskContainer, StreamConfig operatorConfig, StreamRecordCollector collector, long totalMemory, RuntimeContext runtimeContext, OperatorMetricGroup operatorMetricGroup)