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

Packages that use StreamRecordCollector

Package	Description
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.process

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	Description
void	SortMergeJoinFunction.open(boolean adaptiveHashJoin, org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> taskContainer, org.apache.flink.streaming.api.graph.StreamConfig operatorConfig, StreamRecordCollector collector, long totalMemory, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.metrics.groups.OperatorMetricGroup operatorMetricGroup)

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

Subclasses of StreamRecordCollector in org.apache.flink.table.runtime.operators.process

Modifier and Type	Class	Description
class	PassAllCollector	Forwards all columns of the given row.
class	PassPartitionKeysCollector	Forwards partition keys of the given input's row.
class	PassThroughCollectorBase	Base class for collectors that pass input columns.