Serializer#

Serializer#

TypeSerializer(*args, **kwds)

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

VoidNamespaceSerializer(*args, **kwds)

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.