com.ververica.cdc.debezium.table

Class AppendMetadataCollector

java.lang.Object

com.ververica.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 and Description
org.apache.kafka.connect.source.SourceRecord	inputRecord
org.apache.flink.util.Collector<org.apache.flink.table.data.RowData>	outputCollector

Constructor Summary

Constructors

Constructor and Description
AppendMetadataCollector(MetadataConverter[] metadataConverters)

Method Summary

Modifier and Type	Method and 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)

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>