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

Class PassAllCollector

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.PassAllCollector

All Implemented Interfaces:

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

@Internal
public class PassAllCollector
extends PassThroughCollectorBase

Forwards all columns of the given row.

Field Summary

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

prefix

Constructor Summary

Constructors

Constructor	Description
PassAllCollector(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, int prefixRepetition)

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

PassAllCollector

public PassAllCollector(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,
                        int prefixRepetition)

Method Detail

setPrefix

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

Specified by:

setPrefix in class PassThroughCollectorBase