You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/18 04:11:19 UTC
[flink] branch master updated (1892bed -> 1f668dd)

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 1892bed  [FLINK-17386][Security] fix LinkageError not captured during security context initialization.
     add 1f668dd  [FLINK-14255][hive] Integrate hive with parquet and orc format to streaming file sink

No new revisions were added by this update.

Summary of changes:
 ...uter.java => HiveRowDataPartitionComputer.java} |  43 +++--
 ...Computer.java => HiveRowPartitionComputer.java} |   4 +-
 .../flink/connectors/hive/HiveTableFactory.java    |  15 +-
 .../flink/connectors/hive/HiveTableSink.java       | 185 ++++++++++++++++-----
 .../hive/write/HiveOutputFormatFactory.java        |  81 +++++++++
 .../HiveWriterFactory.java}                        | 165 +++++++++---------
 .../flink/table/catalog/hive/client/HiveShim.java  |   9 +
 .../table/catalog/hive/client/HiveShimV100.java    |  10 ++
 .../table/catalog/hive/client/HiveShimV200.java    |  16 ++
 .../hive/HiveOutputFormatFactoryTest.java          |   5 +-
 .../flink/connectors/hive/HiveTableSinkTest.java   | 104 ++++++++++++
 .../orc/nohive/OrcNoHiveBulkWriterFactory.java}    |  79 +++++++--
 .../org/apache/flink/orc/OrcSplitReaderUtil.java   |   2 +-
 .../flink/orc/writer/PhysicalWriterImpl.java       |   2 +-
 .../table/filesystem/FileSystemTableSink.java      |  15 +-
 15 files changed, 554 insertions(+), 181 deletions(-)
 copy flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HivePartitionComputer.java => HiveRowDataPartitionComputer.java} (52%)
 rename flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HivePartitionComputer.java => HiveRowPartitionComputer.java} (94%)
 create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java
 rename flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HiveOutputFormatFactory.java => write/HiveWriterFactory.java} (66%)
 copy flink-formats/{flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java => flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/OrcNoHiveBulkWriterFactory.java} (62%)