pyflink.common.serialization.DeserializationSchema

class DeserializationSchema(j_deserialization_schema=None)

Base class for DeserializationSchema. The deserialization schema describes how to turn the byte messages delivered by certain data sources (for example Apache Kafka) into data types (Java/ Scala objects) that are processed by Flink.

In addition, the DeserializationSchema describes the produced type which lets Flink create internal serializers and structures to handle the type.