pyflink.common.serialization.DeserializationSchema#
- class DeserializationSchema(j_deserialization_schema=None)[source]#
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.