Package org.apache.flink.streaming.util.serialization

Interface DeserializationSchema<T>

  • Type Parameters:
    T - The type created by the deserialization schema.
    All Superinterfaces:
    org.apache.flink.api.common.serialization.DeserializationSchema<T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, Serializable
    All Known Implementing Classes:
    AbstractDeserializationSchema, SimpleStringSchema, TypeInformationSerializationSchema
    @Public
@Deprecated
public interface DeserializationSchema<T>
extends org.apache.flink.api.common.serialization.DeserializationSchema<T>, Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
    Deprecated.
    Use DeserializationSchema 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.

    Note: In most cases, one should start from AbstractDeserializationSchema, which takes care of producing the return type information automatically.

    • 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

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      T deserialize​(byte[] message)
      Deprecated.
      Deserializes the byte message.
      boolean isEndOfStream​(T nextElement)
      Deprecated.
      Method to decide whether the element signals the end of the stream.

      • 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

    • Method Detail

      • deserialize

        T deserialize​(byte[] message)
       throws IOException
        Deprecated.
        Deserializes the byte message.
        Specified by:
        deserialize in interface org.apache.flink.api.common.serialization.DeserializationSchema<T>
        Parameters:
        message - The message, as a byte array.
        Returns:
        The deserialized message as an object (null if the message cannot be deserialized).
        Throws:
        IOException

      • isEndOfStream

        boolean isEndOfStream​(T nextElement)
        Deprecated.
        Method to decide whether the element signals the end of the stream. If true is returned the element won't be emitted.
        Specified by:
        isEndOfStream in interface org.apache.flink.api.common.serialization.DeserializationSchema<T>
        Parameters:
        nextElement - The element to test for the end-of-stream signal.
        Returns:
        True, if the element signals end of stream, false otherwise.