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

Class PassThroughCollectorBase

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

PassAllCollector, PassPartitionKeysCollector

@Internal
public abstract class PassThroughCollectorBase
extends StreamRecordCollector<org.apache.flink.table.data.RowData>

Base class for collectors that pass input columns.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.table.data.RowData	prefix

Constructor Summary

Constructors

Constructor	Description
PassThroughCollectorBase(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	collect(org.apache.flink.table.data.RowData functionOutput)
abstract void	setPrefix(int pos, org.apache.flink.table.data.RowData input)
void	setRowtime(Long time)

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

Field Detail

prefix

protected org.apache.flink.table.data.RowData prefix

Constructor Detail

PassThroughCollectorBase

public PassThroughCollectorBase(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 abstract void setPrefix(int pos,
                               org.apache.flink.table.data.RowData input)

setRowtime

public void setRowtime(Long time)

collect

public void collect(org.apache.flink.table.data.RowData functionOutput)

Specified by:

collect in interface org.apache.flink.util.Collector<org.apache.flink.table.data.RowData>

Overrides:

collect in class StreamRecordCollector<org.apache.flink.table.data.RowData>