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 69c3373 [hotfix][json] Add serialVersionUID to JsonInputFormat class
add 6836184 [FLINK-19599][table] Introduce Filesystem format factories to
integrate new FileSource to table
No new revisions were added by this update.
Summary of changes:
.../parquet/ParquetColumnarRowInputFormat.java | 49 +++--
.../parquet/ParquetFileSystemFormatFactory.java | 205 ++++++---------------
.../parquet/ParquetVectorizedInputFormat.java | 14 +-
.../parquet/ParquetColumnarRowInputFormatTest.java | 22 ++-
.../table/connector/format/BulkDecodingFormat.java | 31 ++--
...atFactory.java => BulkReaderFormatFactory.java} | 21 ++-
...atFactory.java => BulkWriterFormatFactory.java} | 13 +-
.../table/factories/FileSystemFormatFactory.java | 4 +
.../org.apache.flink.table.factories.Factory | 1 -
.../table/filesystem/AbstractFileSystemTable.java | 15 +-
.../table/filesystem/FileSystemTableFactory.java | 79 ++++++--
.../table/filesystem/FileSystemTableSink.java | 90 ++++++---
.../table/filesystem/FileSystemTableSource.java | 137 +++++++++-----
.../filesystem/FileSystemTableFactoryTest.java | 4 +-
.../TestCsvFileSystemFormatFactory.java | 2 +-
.../filesystem}/TestRowDataCsvInputFormat.java | 2 +-
.../org.apache.flink.table.factories.Factory | 2 +-
17 files changed, 365 insertions(+), 326 deletions(-)
copy
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/util/RecyclableIterator.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/format/BulkDecodingFormat.java
(58%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/{DeserializationFormatFactory.java
=> BulkReaderFormatFactory.java} (60%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/{SerializationFormatFactory.java
=> BulkWriterFormatFactory.java} (68%)
rename
flink-table/{flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils
=>
flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem}/TestCsvFileSystemFormatFactory.java
(99%)
rename
flink-table/{flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils
=>
flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem}/TestRowDataCsvInputFormat.java
(99%)
copy {flink-connectors/flink-connector-jdbc/src/main =>
flink-table/flink-table-runtime-blink/src/test}/resources/META-INF/services/org.apache.flink.table.factories.Factory
(92%)
