Class AbstractDeserializationSchema<T>

  • Type Parameters:
    T - The type created by the deserialization schema.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.serialization.DeserializationSchema<T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, DeserializationSchema<T>

    @Deprecated
    @PublicEvolving
    public abstract class AbstractDeserializationSchema<T>
    extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<T>
    implements DeserializationSchema<T>
    Deprecated.
    Use AbstractDeserializationSchema instead.
    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.

    This base variant of the deserialization schema produces the type information automatically by extracting it from the generic class arguments.

    See Also:
    Serialized Form
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

        org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
    • Method Summary

      • Methods inherited from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema

        deserialize, getProducedType, isEndOfStream
      • Methods inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

        deserialize, open
      • Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

        getProducedType
    • Constructor Detail

      • AbstractDeserializationSchema

        public AbstractDeserializationSchema()
        Deprecated.