pyflink.common.serializer.TypeSerializer

class TypeSerializer(*args, **kwds)

This interface describes the methods that are required for a data type to be handled by the Flink runtime. Specifically, this interface contains the serialization and deserialization methods.

Methods

deserialize(stream)	Returns a deserialized element from the input stream.
serialize(element, stream)	Serializes an element to the output stream.