You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:19:21 UTC
[rocketmq-connect] 05/05: Add 'connector/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 386adcc43bf32d201d8ea21ba9abfc653ef4ad17
Merge: fafa276 5da4b78
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 11:18:32 2022 +0800
Add 'connector/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
git-subtree-dir: connector/rocketmq-connect-hudi
git-subtree-mainline: fafa276619b0b6291f0567465590adee55619c8c
git-subtree-split: 5da4b78705108ac6d260283cd38f9be08d2590b9
connector/rocketmq-connect-hudi/README.md | 77 ++++++
connector/rocketmq-connect-hudi/pom.xml | 287 +++++++++++++++++++++
.../rocketmq/connect/hudi/config/CloneUtils.java | 50 ++++
.../rocketmq/connect/hudi/config/ConfigUtil.java | 70 +++++
.../connect/hudi/config/HudiConnectConfig.java | 173 +++++++++++++
.../connect/hudi/config/SinkConnectConfig.java | 139 ++++++++++
.../apache/rocketmq/connect/hudi/config/Utils.java | 75 ++++++
.../connect/hudi/connector/HudiSinkConnector.java | 250 ++++++++++++++++++
.../connect/hudi/connector/HudiSinkTask.java | 111 ++++++++
.../apache/rocketmq/connect/hudi/sink/Updater.java | 239 +++++++++++++++++
.../connect/hudi/strategy/ITaskDivideStrategy.java | 27 ++
.../hudi/strategy/TaskDivideByQueueStrategy.java | 80 ++++++
.../hudi/strategy/TaskDivideStrategyFactory.java | 25 ++
.../rocketmq-connect-hudi/style/rmq_checkstyle.xml | 135 ++++++++++
14 files changed, 1738 insertions(+)
diff --cc connector/rocketmq-connect-hudi/README.md
index 0000000,cadc364..cadc364
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/README.md
+++ b/connector/rocketmq-connect-hudi/README.md
diff --cc connector/rocketmq-connect-hudi/pom.xml
index 0000000,97c8785..97c8785
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/pom.xml
+++ b/connector/rocketmq-connect-hudi/pom.xml
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
index 0000000,dc3605d..dc3605d
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
index 0000000,88f8a8e..88f8a8e
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
index 0000000,4c04605..4c04605
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
index 0000000,943df40..943df40
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
index 0000000,d9bc6fe..d9bc6fe
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
index 0000000,a496418..a496418
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
index 0000000,b01c660..b01c660
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
index 0000000,8e7e288..8e7e288
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
index 0000000,a91c066..a91c066
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
index 0000000,c68e17c..c68e17c
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
diff --cc connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
index 0000000,1d693a8..1d693a8
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
+++ b/connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
diff --cc connector/rocketmq-connect-hudi/style/rmq_checkstyle.xml
index 0000000,776b305..776b305
mode 000000,100644..100644
--- a/connector/rocketmq-connect-hudi/style/rmq_checkstyle.xml
+++ b/connector/rocketmq-connect-hudi/style/rmq_checkstyle.xml