org.apache.flink.formats.json.canal
Classes
CanalJsonDeserializationSchema
CanalJsonFormatFactory