Class Hierarchy
- java.lang.Object
- org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVEventDeserializationSchemaBase (implements java.io.Serializable)
- org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVChangeEventDeserializationSchema (implements org.apache.flink.cdc.connectors.tidb.TiKVChangeEventDeserializationSchema<T>)
- org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVSnapshotEventDeserializationSchema (implements org.apache.flink.cdc.connectors.tidb.TiKVSnapshotEventDeserializationSchema<T>)
- org.apache.flink.cdc.connectors.tidb.table.StartupOptions
- org.apache.flink.cdc.connectors.tidb.table.TiDBTableSource (implements org.apache.flink.table.connector.source.ScanTableSource, org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata)
- org.apache.flink.cdc.connectors.tidb.table.TiDBTableSourceFactory (implements org.apache.flink.table.factories.DynamicTableSourceFactory)
- org.apache.flink.cdc.connectors.tidb.table.TiKVAppendMetadataCollector (implements org.apache.flink.util.Collector<T>, java.io.Serializable)
- org.apache.flink.cdc.connectors.tidb.table.TiKVMetadataConverter.TiKVRowValue
- org.apache.flink.cdc.connectors.tidb.table.TiKVReadableMetadata
- org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVEventDeserializationSchemaBase (implements java.io.Serializable)
Interface Hierarchy
- java.io.Serializable
- org.apache.flink.cdc.connectors.tidb.table.TiKVDeserializationRuntimeConverter
- org.apache.flink.cdc.connectors.tidb.table.TiKVMetadataConverter
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.flink.cdc.connectors.tidb.table.StartupMode
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)