Package org.apache.flink.cdc.debezium.table

Class AppendMetadataCollector

java.lang.Object

org.apache.flink.cdc.debezium.table.AppendMetadataCollector

All Implemented Interfaces:

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

@Internal
public final class AppendMetadataCollector
extends Object
implements org.apache.flink.util.Collector<org.apache.flink.table.data.RowData>, Serializable

Emits a row with physical fields and metadata fields.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
org.apache.kafka.connect.source.SourceRecord	inputRecord
org.apache.flink.util.Collector<org.apache.flink.table.data.RowData>	outputCollector

Constructor Summary

Constructors

Constructor	Description
AppendMetadataCollector(MetadataConverter[] metadataConverters)
AppendMetadataCollector(MetadataConverter[] metadataConverters, boolean appendOnly)

Method Summary

Modifier and Type	Method	Description
void	close()
void	collect(org.apache.flink.table.data.RowData physicalRow)

Methods inherited from class java.lang.Object

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

Field Detail

inputRecord

public transient org.apache.kafka.connect.source.SourceRecord inputRecord

outputCollector

public transient org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> outputCollector

Constructor Detail

AppendMetadataCollector

public AppendMetadataCollector(MetadataConverter[] metadataConverters)

AppendMetadataCollector

public AppendMetadataCollector(MetadataConverter[] metadataConverters,
                               boolean appendOnly)

Method Detail

collect

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

Specified by:

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

close

public void close()

Specified by:

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