pyflink.datastream.formats.csv.CsvBulkWriters#
- class CsvBulkWriters[source]#
CsvBulkWriter is for building
BulkWriterFactory
to write Rows with a predefined CSV schema to partitioned files in a bulk fashion.Example:
>>> schema = CsvSchema.builder() \ ... .add_number_column('id', number_type=DataTypes.INT()) \ ... .add_string_column('name') \ ... .add_array_column('list', ',', element_type=DataTypes.STRING()) \ ... .set_column_separator('|') \ ... .build() >>> sink = FileSink.for_bulk_format( ... OUTPUT_DIR, CsvBulkWriters.for_schema(schema)).build() >>> ds.sink_to(sink)
New in version 1.16.0.
Methods
for_schema
(schema)Creates a
BulkWriterFactory
for writing records to files in CSV format.