Package org.apache.flink.cdc.connectors.tidb.table

Class TiKVAppendMetadataCollector

java.lang.Object

org.apache.flink.cdc.connectors.tidb.table.TiKVAppendMetadataCollector

All Implemented Interfaces:

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

public class TiKVAppendMetadataCollector
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.flink.util.Collector<org.apache.flink.table.data.RowData>	outputCollector
TiKVMetadataConverter.TiKVRowValue	row

Constructor Summary

Constructors

Constructor	Description
TiKVAppendMetadataCollector(TiKVMetadataConverter[] metadataConverters)

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

row

public transient TiKVMetadataConverter.TiKVRowValue row

outputCollector

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

Constructor Detail

TiKVAppendMetadataCollector

public TiKVAppendMetadataCollector(TiKVMetadataConverter[] 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>