Package org.apache.flink.formats.csv

Class CsvRowDeserializationSchema

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>
    @PublicEvolving
@Deprecated
public final class CsvRowDeserializationSchema
extends Object
implements org.apache.flink.api.common.serialization.DeserializationSchema<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 DeserializationSchema.
    Deserialization schema from CSV to Flink types.

    Deserializes a byte[] message as a JsonNode and converts it to Row.

    Failure during deserialization are forwarded as wrapped IOExceptions.

    See Also:
    Serialized Form

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  CsvRowDeserializationSchema.Builder
      Deprecated.
      A builder for creating a CsvRowDeserializationSchema.

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

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

    • Method Detail

      • open

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

      • deserialize

        public org.apache.flink.types.Row deserialize​(byte[] message)
                                       throws IOException
        Deprecated.
        Specified by:
        deserialize in interface org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>
        Throws:
        IOException

      • isEndOfStream

        public boolean isEndOfStream​(org.apache.flink.types.Row nextElement)
        Deprecated.
        Specified by:
        isEndOfStream in interface org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>

      • getProducedType

        public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getProducedType()
        Deprecated.
        Specified by:
        getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<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