Package org.apache.paimon.flink.action.cdc.format.debezium

Class Summary

Class	Description
DebeziumAvroDataFormat	Supports the message queue's debezium avro data format and provides definitions for the message queue's record avro deserialization class and parsing class DebeziumAvroRecordParser.
DebeziumAvroDataFormatFactory	Factory to create DebeziumAvroDataFormat.
DebeziumAvroRecordParser	Implementation of AbstractRecordParser for parsing messages in the Debezium avro format.
DebeziumJsonDataFormat	Supports the message queue's debezium json data format and provides definitions for the message queue's record json deserialization class and parsing class DebeziumJsonRecordParser.
DebeziumJsonDataFormatFactory	Factory to create DebeziumJsonDataFormat.
DebeziumJsonRecordParser	The DebeziumRecordParser class extends the abstract AbstractJsonRecordParser and is designed to parse records from Debezium's JSON change data capture (CDC) format.
DebeziumSchemaUtils	Utils to handle 'schema' field in debezium Json.