Serializer

Serializer

TypeSerializer()	This interface describes the methods that are required for a data type to be handled by the Flink runtime.
VoidNamespaceSerializer()

Serialization

SerializationSchema([j_serialization_schema])	Base class for SerializationSchema.
DeserializationSchema([j_deserialization_schema])	Base class for DeserializationSchema.
SimpleStringSchema([charset])	Very simple serialization/deserialization schema for strings.
Encoder(j_encoder)	Encoder is used by the file sink to perform the actual writing of the incoming elements to the files in a bucket.
BulkWriterFactory(j_bulk_writer_factory)	The Python wrapper of Java BulkWriter.Factory interface, which is the base interface for data sinks that write records into files in a bulk manner.
RowDataBulkWriterFactory(...)	A ～BulkWriterFactory that receives records with RowData type.