[inlong] branch master updated (f14f2424f -> ad7646f80)

[do...@apache.org]

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%)