Package | Description |
---|---|
org.apache.flink.formats.json.canal | |
org.apache.flink.formats.json.debezium | |
org.apache.flink.formats.json.maxwell |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonDecodingFormat
DecodingFormat for Canal using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonDecodingFormat
DecodingFormat for Debezium using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellJsonDecodingFormat
DecodingFormat for Maxwell using JSON encoding. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.