Package org.apache.flink.cdc.debezium.table

Interface Summary

Interface	Description
DeserializationRuntimeConverter	Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal data structures.
DeserializationRuntimeConverterFactory	Factory to create DeserializationRuntimeConverter according to LogicalType.
MetadataConverter	A converter converts SourceRecord metadata into Flink internal data structures.
RowDataDebeziumDeserializeSchema.ValueValidator	Custom validator to validate the row value.
RowDataMetadataConverter	A converter converts RowData metadata into Flink internal data structures.

Class Summary

Class	Description
AppendMetadataCollector	Emits a row with physical fields and metadata fields.
DebeziumOptions	Option utils for Debezium options.
RowDataDebeziumDeserializeSchema	Deserialization schema from Debezium object to Flink Table/SQL internal data structure RowData.
RowDataDebeziumDeserializeSchema.Builder	Builder of RowDataDebeziumDeserializeSchema.

Enum Summary

Enum	Description
DebeziumChangelogMode	Changelog modes used to encode changes from Debezium to Flink internal structure.