| Class | Description |
|---|---|
| DebeziumJsonDecodingFormat |
DecodingFormat for Debezium using JSON encoding. |
| DebeziumJsonDeserializationSchema |
Deserialization schema from Debezium JSON to Flink Table/SQL internal data structure
RowData. |
| DebeziumJsonFormatFactory |
Format factory for providing configured instances of Debezium JSON to RowData
DeserializationSchema. |
| DebeziumJsonFormatOptions |
Option utils for debezium-json format.
|
| DebeziumJsonSerializationSchema |
Serialization schema from Flink Table/SQL internal data structure
RowData to Debezium
JSON. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.