org.apache.flink.formats.json.canal

Classes

• CanalJsonDecodingFormat
• CanalJsonDeserializationSchema
• CanalJsonDeserializationSchema.Builder
• CanalJsonFormatFactory
• CanalJsonFormatOptions
• CanalJsonSerializationSchema