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/incubator-inlong.git.
from d74d7b6 [INLONG-2183][Feature][InLong-Sort] Bump flink version to
1.13.5 (#2184)
add 67bf8bf [INLONG-1895] Inlong-Sort-Standalone support to sort the
events to Hive cluster. (#2129)
No new revisions were added by this update.
Summary of changes:
inlong-sort-standalone/conf/common.properties | 15 +-
.../conf/{ => hive}/common.properties | 15 +-
.../conf/hive/getClusterConfig.json | 108 +++++
inlong-sort-standalone/conf/hive/hive.sql | 77 ++++
inlong-sort-standalone/pom.xml | 68 +++
.../src/main/assembly/assembly.xml | 10 +-
.../sort/standalone/dispatch/DispatchManager.java | 18 +-
.../sort/standalone/dispatch/DispatchProfile.java | 25 +-
.../sink/hive/DefaultEventFormatHandler.java | 62 +++
.../sort/standalone/sink/hive/HdfsIdConfig.java | 339 +++++++++++++++
.../sort/standalone/sink/hive/HdfsIdFile.java | 257 +++++++++++
.../inlong/sort/standalone/sink/hive/HiveSink.java | 242 +++++++++++
.../sort/standalone/sink/hive/HiveSinkContext.java | 470 +++++++++++++++++++++
.../standalone/sink/hive/IEventFormatHandler.java | 14 +-
.../sink/hive/PartitionCreateRunnable.java | 330 +++++++++++++++
.../sink/hive/PartitionLeaderElectionRunnable.java | 242 +++++++++++
.../sort/standalone/sink/hive/PartitionState.java | 11 +-
.../sink/hive/WriteHdfsFileRunnable.java | 76 ++++
18 files changed, 2345 insertions(+), 34 deletions(-)
copy inlong-sort-standalone/conf/{ => hive}/common.properties (57%)
create mode 100644 inlong-sort-standalone/conf/hive/getClusterConfig.json
create mode 100644 inlong-sort-standalone/conf/hive/hive.sql
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/DefaultEventFormatHandler.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/HdfsIdConfig.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/HdfsIdFile.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/HiveSink.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/HiveSinkContext.java
copy
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/loader/CommonPropertiesLoader.java
=>
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/IEventFormatHandler.java
(74%)
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/PartitionCreateRunnable.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/PartitionLeaderElectionRunnable.java
copy
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/SegmentType.java
=>
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/PartitionState.java
(84%)
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/hive/WriteHdfsFileRunnable.java
