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

Interface Summary

Interface	Description
TiKVChangeEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV Change Event into data types (Java/Scala objects) that are processed by Flink.
TiKVSnapshotEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV snapshot event into data types (Java/Scala objects) that are processed by Flink.

Class Summary

Class	Description
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
TDBSourceOptions	Configurations for TiDBSource.
TiDBSource	A builder to build a SourceFunction which can read snapshot and continue to read CDC events.
TiDBSource.Builder<T>	Builder class of TiDBSource.
TiKVRichParallelSourceFunction<T>	The source implementation for TiKV that read snapshot events first and then read the change event.