Class JsonRowSerializationSchema

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>

    @PublicEvolving
    @Deprecated
    public class JsonRowSerializationSchema
    extends Object
    implements org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
    Deprecated.
    The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.
    Serialization schema that serializes an object of Flink types into a JSON bytes.

    Serializes the input Flink object into a JSON string and converts it into byte[].

    Result byte[] messages can be deserialized using JsonRowDeserializationSchema.

    See Also:
    Serialized Form
    • Method Detail

      • open

        public void open​(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)
                  throws Exception
        Deprecated.
        Specified by:
        open in interface org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
        Throws:
        Exception
      • serialize

        public byte[] serialize​(org.apache.flink.types.Row row)
        Deprecated.
        Specified by:
        serialize in interface org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
      • equals

        public boolean equals​(Object o)
        Deprecated.
        Overrides:
        equals in class Object
      • hashCode

        public int hashCode()
        Deprecated.
        Overrides:
        hashCode in class Object