Package org.apache.flink.cdc.debezium

Interface Summary

Interface	Description
DebeziumDeserializationSchema<T>	The deserialization schema describes how to turn the Debezium SourceRecord into data types (Java/Scala objects) that are processed by Flink.
Validator	Validator to validate the connected database satisfies the cdc connector's requirements.

Class Summary

Class	Description
DebeziumSourceFunction<T>	The DebeziumSourceFunction is a streaming data source that pulls captured change data from databases into Flink.
JsonDebeziumDeserializationSchema	A JSON format implementation of DebeziumDeserializationSchema which deserializes the received SourceRecord to JSON String.
StringDebeziumDeserializationSchema	A simple implementation of DebeziumDeserializationSchema which converts the received SourceRecord into String.