pyflink.datastream.formats.csv.CsvRowDeserializationSchema

class CsvRowDeserializationSchema(j_deserialization_schema)

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 IOException.