pyflink.common.serialization.SerializationSchema

class SerializationSchema(j_serialization_schema=None)

Base class for SerializationSchema. The serialization schema describes how to turn a data object into a different serialized representation. Most data sinks (for example Apache Kafka) require the data to be handed to them in a specific format (for example as byte strings).