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 19eb503 [FLINK-20006] Fix the unstable FileSinkITCase
add f6be70b [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk
Format
No new revisions were added by this update.
Summary of changes:
.../flink/orc/AbstractOrcFileInputFormat.java | 302 ++++++++++++++
.../flink/orc/OrcColumnarRowFileInputFormat.java | 171 ++++++++
.../apache/flink/orc/OrcFileFormatFactory.java} | 130 +++---
.../flink/orc/OrcFileSystemFormatFactory.java | 225 -----------
.../main/java/org/apache/flink/orc/OrcFilters.java | 2 +-
.../org/apache/flink/orc/OrcSplitReaderUtil.java | 18 +-
.../orc/util/SerializableHadoopConfigWrapper.java | 78 ++++
.../flink/orc/vector/ColumnBatchFactory.java | 14 +-
.../org.apache.flink.table.factories.Factory | 2 +-
.../orc/OrcColumnarRowFileInputFormatTest.java | 435 +++++++++++++++++++++
.../apache/flink/orc/OrcFileSystemFilterTest.java | 2 +-
.../org/apache/flink/orc/OrcFileSystemITCase.java | 2 +-
.../apache/flink/orc/OrcFsStreamingSinkITCase.java | 2 +-
...tFactory.java => ParquetFileFormatFactory.java} | 2 +-
.../org.apache.flink.table.factories.Factory | 2 +-
.../parquet/ParquetFileCompactionITCase.java | 2 +-
.../formats/parquet/ParquetFileSystemITCase.java | 2 +-
.../parquet/ParquetFsStreamingSinkITCase.java | 2 +-
.../table/filesystem/ColumnarRowIterator.java | 13 +-
19 files changed, 1113 insertions(+), 293 deletions(-)
create mode 100644
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/AbstractOrcFileInputFormat.java
create mode 100644
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcColumnarRowFileInputFormat.java
copy
flink-formats/{flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileSystemFormatFactory.java
=> flink-orc/src/main/java/org/apache/flink/orc/OrcFileFormatFactory.java}
(59%)
delete mode 100644
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
create mode 100644
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/util/SerializableHadoopConfigWrapper.java
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveObjectConversion.java
=>
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/ColumnBatchFactory.java
(69%)
create mode 100644
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcColumnarRowFileInputFormatTest.java
rename
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/{ParquetFileSystemFormatFactory.java
=> ParquetFileFormatFactory.java} (97%)
