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 <[email protected]> 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
