This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 6517e5fad3 [INLONG-8134][Dashboard] Group supports viewing resource
details (#8139)
add 266abfe2f2 [INLONG-8092][Sort] Support all database and multiple
tables transmission for Hive (#8096)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/sort/base/Constants.java | 15 +
.../inlong/sort/base/sink/PartitionPolicy.java | 29 +-
.../sort-flink-v1.13/sort-connectors/hive/pom.xml | 303 +++++---
.../inlong/sort/hive/HiveBulkWriterFactory.java | 55 ++
.../org/apache/inlong/sort/hive/HiveOptions.java | 31 +
.../inlong/sort/hive/HiveOutputFormatFactory.java | 77 ++
.../sort/hive/HiveRowDataPartitionComputer.java | 152 +++-
.../sort/hive/HiveTableMetaStoreFactory.java | 12 +-
.../org/apache/inlong/sort/hive/HiveTableSink.java | 129 +++-
.../apache/inlong/sort/hive/HiveWriterFactory.java | 251 +++++++
.../hive/filesystem/AbstractStreamingWriter.java | 118 +--
.../DefaultHadoopFileCommitterFactory.java | 49 ++
.../HadoopPathBasedBulkFormatBuilder.java | 217 ++++++
.../filesystem/HadoopPathBasedPartFileWriter.java | 816 +++++++++++++++++++++
.../hive/filesystem/HadoopRenameFileCommitter.java | 162 ++++
.../InLongHadoopPathBasedBulkWriter.java | 93 +++
.../sort/hive/filesystem/PartitionCommitter.java | 363 +++++++++
.../inlong/sort/hive/filesystem/StreamingSink.java | 9 +-
.../sort/hive/table/HiveTableInlongFactory.java | 64 +-
.../apache/inlong/sort/hive/util/CacheHolder.java | 84 +++
.../inlong/sort/hive/util/HiveTableUtil.java | 594 +++++++++++++++
licenses/inlong-sort-connectors/LICENSE | 8 +
22 files changed, 3348 insertions(+), 283 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/SinkStatus.java
=>
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/sink/PartitionPolicy.java
(64%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveBulkWriterFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveOutputFormatFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveWriterFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/DefaultHadoopFileCommitterFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedBulkFormatBuilder.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedPartFileWriter.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopRenameFileCommitter.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/InLongHadoopPathBasedBulkWriter.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/PartitionCommitter.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/util/CacheHolder.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/util/HiveTableUtil.java
