Hi You can create a `BulkWriter.Factory` which will create `CsvBulkWriter` and create `FileSink` by `FileSink.forBulkFormat`. You can see the detail in `DataStreamCsvITCase.testCustomBulkWriter`
Best, Shammon On Tue, Mar 7, 2023 at 7:41 PM Chirag Dewan via user <user@flink.apache.org> wrote: > 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 >
