Hi,
I am working on a Java DataStream application and need to implement a File sink 
with CSV format.
I see that I have two options here - Row and Bulk 
(https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/datastream/filesystem/#format-types-1)
So for CSV file distribution which one should I use? Row or Bulk?
I think the documentation is confusing for File connectors. Because I can see 
an example for PyFlink which uses a BulkWriter for CSV. But the same class is 
not public in flink-csv. So does Flink not support CSVBulkWriter for Java?
And for Table API File sink explicitly supports CSV for Row format. But fails 
to mention anything about CSV in DataStream File sink. 
This all is just really confusing. Any leads on this are much appreciated.
Thanks

Reply via email to