Class | Description |
---|---|
DebeziumAvroDeserializationSchema |
Deserialization schema from Debezium Avro to Flink Table/SQL internal data structure
RowData . |
DebeziumAvroFormatFactory |
Format factory for providing configured instances of Debezium Avro to RowData
DeserializationSchema . |
DebeziumAvroSerializationSchema |
Serialization schema from Flink Table/SQL internal data structure
RowData to Debezium
Avro. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.