This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from aa1ede9 [FLINK-16845] Adds implmentation of SourceOperator. This
patch does the following: 1. Add CoordinatedOperatorFactory interface. 2.
Rename SourceReaderOpertor to SourceOperator, add implementation and connect it
to OperatorEventGateway. 3. Rename SourceReaderStreamTask to
SourceOperatorStreamTask 4. Fix some bugs in StreamTaskMailboxTestHarness.
add 66308f8 [FLINK-14257][table][filesystem] Integrate CSV to
FileSystemTableFactory
No new revisions were added by this update.
Summary of changes:
flink-formats/flink-csv/pom.xml | 15 +
.../formats/csv/CsvFileSystemFormatFactory.java | 341 +++++++++++++++++++++
.../csv/CsvRowDataDeserializationSchema.java | 4 +-
.../org.apache.flink.table.factories.TableFactory | 1 +
.../formats/csv/CsvFilesystemBatchITCase.java | 103 +++++++
.../formats/csv/CsvFilesystemStreamITCase.java} | 9 +-
6 files changed, 466 insertions(+), 7 deletions(-)
create mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileSystemFormatFactory.java
create mode 100644
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFilesystemBatchITCase.java
copy
flink-formats/{flink-json/src/test/java/org/apache/flink/formats/json/JsonFsStreamSinkITCase.java
=>
flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFilesystemStreamITCase.java}
(83%)
