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

Interface SerializationSchema<T>

  • Type Parameters:
    T - The type to be serialized.
    All Superinterfaces:
    Serializable, org.apache.flink.api.common.serialization.SerializationSchema<T>
    All Known Implementing Classes:
    SimpleStringSchema, TypeInformationSerializationSchema
    @Public
@Deprecated
public interface SerializationSchema<T>
extends org.apache.flink.api.common.serialization.SerializationSchema<T>, Serializable
    Deprecated.
    Use SerializationSchema instead.
    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).

    • Nested Class Summary

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

        org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext

    • Method Summary

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      byte[] serialize​(T element)
      Deprecated.
      Serializes the incoming element to a specified type.

      • Methods inherited from interface org.apache.flink.api.common.serialization.SerializationSchema

        open

    • Method Detail

      • serialize

        byte[] serialize​(T element)
        Deprecated.
        Serializes the incoming element to a specified type.
        Specified by:
        serialize in interface org.apache.flink.api.common.serialization.SerializationSchema<T>
        Parameters:
        element - The incoming element to be serialized
        Returns:
        The serialized element.