Package org.apache.flink.formats.json.canal

Class Summary

Class	Description
CanalJsonDecodingFormat	DecodingFormat for Canal using JSON encoding.
CanalJsonDeserializationSchema	Deserialization schema from Canal JSON to Flink Table/SQL internal data structure RowData.
CanalJsonDeserializationSchema.Builder	A builder for creating a CanalJsonDeserializationSchema.
CanalJsonFormatFactory	Format factory for providing configured instances of Canal JSON to RowData DeserializationSchema.
CanalJsonFormatOptions	Option utils for canal-json format.
CanalJsonSerializationSchema	Serialization schema that serializes an object of Flink Table/SQL internal data structure RowData into a Canal JSON bytes.