pyflink.common.serialization.CsvRowSerializationSchema

class CsvRowSerializationSchema(j_csv_row_serialization_schema)

Serialization schema that serializes an object of Flink types into a CSV bytes. Serializes the input row into an ObjectNode and converts it into byte[].

Result byte[] messages can be deserialized using CsvRowDeserializationSchema.