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

Class PassPartitionKeysCollector

java.lang.Object

org.apache.flink.table.runtime.util.StreamRecordCollector<org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.operators.process.PassThroughCollectorBase

org.apache.flink.table.runtime.operators.process.PassPartitionKeysCollector

All Implemented Interfaces:

org.apache.flink.util.Collector<org.apache.flink.table.data.RowData>

@Internal
public class PassPartitionKeysCollector
extends PassThroughCollectorBase

Forwards partition keys of the given input's row.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.process.PassThroughCollectorBase

prefix

Constructor Summary

Constructors

Constructor	Description
PassPartitionKeysCollector(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>> output, org.apache.flink.table.connector.ChangelogMode changelogMode, List<RuntimeTableSemantics> tableSemantics)

Method Summary

Modifier and Type	Method	Description
void	setPrefix(int pos, org.apache.flink.table.data.RowData input)

Methods inherited from class org.apache.flink.table.runtime.operators.process.PassThroughCollectorBase

collect, setRowtime

Methods inherited from class org.apache.flink.table.runtime.util.StreamRecordCollector

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PassPartitionKeysCollector

public PassPartitionKeysCollector(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>> output,
                                  org.apache.flink.table.connector.ChangelogMode changelogMode,
                                  List<RuntimeTableSemantics> tableSemantics)

Method Detail

setPrefix

public void setPrefix(int pos,
                      org.apache.flink.table.data.RowData input)

Specified by:

setPrefix in class PassThroughCollectorBase