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

Interface Summary

Interface	Description
TiKVDeserializationRuntimeConverter	Runtime converter that converts objects of TiKV into objects of Flink Table & SQL internal data structures.
TiKVMetadataConverter	A converter converts TiKV Row metadata into Flink internal data structures.

Class Summary

Class	Description
RowDataTiKVChangeEventDeserializationSchema	Deserialization schema from TiKV Change Event to Flink Table/SQL internal data structure RowData.
RowDataTiKVEventDeserializationSchemaBase	Base class of deserialization schema from TiKV RowValue (Snapshot or Change Event) to Flink Table/SQL internal data structure RowData.
RowDataTiKVSnapshotEventDeserializationSchema	Deserialization schema from TiKV Snapshot Event to Flink Table/SQL internal data structure RowData.
StartupOptions	TiDB CDC Source startup options.
TiDBTableSource	A DynamicTableSource that describes how to create a TiDB change event stream from a logical description.
TiDBTableSourceFactory	Factory for creating configured instance of TiDBTableSource.
TiKVAppendMetadataCollector	Emits a row with physical fields and metadata fields.
TiKVMetadataConverter.TiKVRowValue	TiKV Row Value.
TiKVReadableMetadata	Defines the supported metadata columns for TiDBTableSource.

Enum Summary

Enum	Description
StartupMode	Startup modes for the TiDB CDC Consumer.