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 | 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 | Description |
---|---|
StartupMode |
Startup modes for the TiDB CDC Consumer.
|
Copyright © 2025 The Apache Software Foundation. All rights reserved.