Hi Chirag
CSVBulkWriter implements BulkWriter and no special methods are added in
CSVBulkWriter. I think you can use BulkWriter instead of CSVBulkWriter in
your application directly. You can have a try, thanks
Best,
Shammon
On Fri, Mar 10, 2023 at 4:05 PM Shammon FY wrote:
>
>
Thanks for the reply Shammom. I looked at the DataStreamCsvITCase - it gives a
very good example. I can implement something similar. However, the
CSVBulkWriter that is uses to create a factory, has a default package access
which can be accessed from this test case, but not from my application.
---
> *发件人: *"User"
> *收件人: *"User"
> *发送时间: *星期二, 2023年 3 月 07日 下午 7:35:47
> *主题: *CSV File Sink in Streaming Use Case
>
> Hi,
>
> I am working on a Java DataStream application and need to implement a File
> sink with CSV format.
>
> I
, 2023年 3 月 07日 下午 7:35:47
主题: CSV File Sink in Streaming Use Case
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/connecto
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
wrote:
> Hi,
>
> I am working o
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 wh
