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 f14f2424f [INLONG-6970][Agent] Improve UnitTest for PulsarSink (#6971)
add ad7646f80 [INLONG-6858][Sort] Support extract node of Apache Hudi
(#6942)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/common/enums/TaskTypeEnum.java | 3 +
.../inlong/manager/common/consts/SourceType.java | 2 +
.../manager/pojo/sort/util/ExtractNodeUtils.java | 32 +++++
.../{mqtt/MqttSource.java => hudi/HudiSource.java} | 50 ++++---
.../HudiSourceDTO.java} | 64 +++++----
.../hudi/HudiSourceRequest.java} | 46 +++----
.../HudiSourceOperator.java} | 32 +++--
.../sort/protocol/constant/HudiConstant.java | 119 +++++++++++++++++
.../inlong/sort/protocol/node/ExtractNode.java | 4 +-
.../org/apache/inlong/sort/protocol/node/Node.java | 2 +
.../HudiExtractNode.java} | 146 +++++++++------------
...tractNodeTest.java => HudiExtractNodeTest.java} | 35 +++--
12 files changed, 347 insertions(+), 188 deletions(-)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/{mqtt/MqttSource.java
=> hudi/HudiSource.java} (57%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/{mongodb/MongoDBSourceDTO.java
=> hudi/HudiSourceDTO.java} (55%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/{sink/hudi/HudiSinkRequest.java
=> source/hudi/HudiSourceRequest.java} (57%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/{redis/RedisSourceOperator.java
=> hudi/HudiSourceOperator.java} (75%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/{load/HudiLoadNode.java
=> extract/HudiExtractNode.java} (50%)
copy
inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/node/extract/{DorisExtractNodeTest.java
=> HudiExtractNodeTest.java} (70%)
