[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r797813488 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792689731 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792689731 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792685482 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java ## @@ -109,17 +110,21 @@ public

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792676507 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792676507 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792672907 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792672907 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r792672907 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java ## @@ -155,16 +169,34 @@ private static

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r790581794 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,112 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789624039 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,351 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789562890 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,363 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789576905 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789565174 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,363 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789562890 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,363 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789558120 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,363 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789503305 ## File path: flink-formats/flink-csv/pom.xml ## @@ -77,6 +77,14 @@ under the License. + Review comment:

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r780379983 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r780379983 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779815815 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779611383 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779599031 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779598732 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779596112 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,351 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779588908 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779584052 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,351 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779513508 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r779500430 ## File path: flink-formats/flink-format-common/src/main/java/org/apache/flink/formats/common/Converter.java ## @@ -0,0 +1,39 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r778892987 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -82,41 +102,86 @@ public void

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r773805659 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r773800347 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r773800347 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r773800347 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r773800347 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771443163 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771443163 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771428588 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771428588 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771428588 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,289 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r771408712 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770834164 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770834164 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770679363 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770835661 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770835661 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770835661 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770834164 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770781617 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770722990 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770696351 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770696351 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770679363 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770679363 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -19,103 +19,48 @@ package

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770475079 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -125,128 +70,88 @@ public String

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770169936 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770169936 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770161770 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770161770 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770157114 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -125,128 +70,88 @@ public String

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770157114 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -125,128 +70,88 @@ public String

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770140011 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvToRowDataConverters.java ## @@ -305,7 +311,7 @@ private

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770126659 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770126659 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache