| Package | Description |
|---|---|
| com.ververica.cdc.debezium.table |
| Class and 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
Deserialization schema from Debezium object to Flink Table/SQL internal data structure
RowData. |
| RowDataDebeziumDeserializeSchema.Builder
Builder of
RowDataDebeziumDeserializeSchema. |
| RowDataDebeziumDeserializeSchema.ValueValidator
Custom validator to validate the row value.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.