Formats

Avro

AvroRowDeserializationSchema([record_class, ...])	Deserialization schema from Avro bytes to Row.
AvroRowSerializationSchema([record_class, ...])	Serialization schema that serializes to Avro binary format.

CSV

CsvRowDeserializationSchema(...)	Deserialization schema from CSV to Flink types.
CsvRowSerializationSchema(...)	Serialization schema that serializes an object of Flink types into a CSV bytes.

Json

JsonRowDeserializationSchema(...)	Deserialization schema from JSON to Flink types.
JsonRowSerializationSchema(...)	Serialization schema that serializes an object of Flink types into a JSON bytes.