This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9df1980 [FLINK-25810][connector/kinesis] Adding Kinesis data streams
SQL client uber jar and end to end test.
add c31452b [FLINK-24703][connectors][format] Adds CSV File System
decoding format based on file-connector-files StreamFormat.
add ca58a70 [FLINK-24703][connectors][format] Add CSV File System
encoding format based on BulkWriter.
No new revisions were added by this update.
Summary of changes:
.../apache/flink/formats/csv/CsvBulkWriter.java | 112 ++++++
.../org/apache/flink/formats/csv/CsvCommons.java | 117 ++++++
.../flink/formats/csv/CsvFileFormatFactory.java | 202 ++++++++++
.../formats/csv/CsvFileSystemFormatFactory.java | 282 --------------
.../apache/flink/formats/csv/CsvFormatFactory.java | 78 +---
.../apache/flink/formats/csv/CsvReaderFormat.java | 212 +++++++++++
.../formats/csv/CsvRowDataSerializationSchema.java | 10 +-
.../flink/formats/csv/CsvToRowDataConverters.java | 10 +-
.../flink/formats/csv/RowDataToCsvConverters.java | 27 +-
.../org.apache.flink.table.factories.Factory | 2 +-
.../formats/csv/CsvFilesystemBatchITCase.java | 17 +-
.../flink/formats/csv/CsvFormatFactoryTest.java | 2 +-
.../flink/formats/csv/DataStreamCsvITCase.java | 411 +++++++++++++++++++++
.../flink/formats/csv/TableCsvFormatITCase.java | 70 +++-
.../org.apache.flink.table.factories.Factory | 2 +-
.../org/apache/flink/formats/common/Converter.java | 21 +-
.../table/planner/utils/JsonPlanTestBase.java | 37 +-
17 files changed, 1211 insertions(+), 401 deletions(-)
create mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java
create mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvCommons.java
create mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java
delete mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileSystemFormatFactory.java
create mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java
create mode 100644
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/TableSourceJsonPlanITCase.java
=>
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java
(66%)
copy flink-formats/flink-csv/src/{main =>
test}/resources/META-INF/services/org.apache.flink.table.factories.Factory (93%)
copy
flink-core/src/main/java/org/apache/flink/api/common/distributions/RangeBoundaries.java
=>
flink-formats/flink-format-common/src/main/java/org/apache/flink/formats/common/Converter.java
(60%)
