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.