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 b27e75b49 [INLONG-6428][Sort] Add connector to support
elasticsearch-5.X (#6583)
add 09f257b17 [INLONG-6745][Manager] Support StarRocks load node
management (#6746)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/consts/SinkType.java | 1 +
.../StarRocksSink.java} | 36 +++----
.../StarRocksSinkDTO.java} | 45 +++++----
.../StarRocksSinkRequest.java} | 30 +++---
.../manager/pojo/sort/util/LoadNodeUtils.java | 48 +++++++++
.../StarRocksSinkOperator.java} | 42 ++++----
.../{DorisConstant.java => StarRocksConstant.java} | 38 +++++--
.../{DorisLoadNode.java => StarRocksLoadNode.java} | 111 ++++++++++-----------
8 files changed, 210 insertions(+), 141 deletions(-)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/{doris/DorisSink.java
=> starrocks/StarRocksSink.java} (72%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/{doris/DorisSinkDTO.java
=> starrocks/StarRocksSinkDTO.java} (74%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/{doris/DorisSinkRequest.java
=> starrocks/StarRocksSinkRequest.java} (72%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/{iceberg/DLCIcebergSinkOperator.java
=> starrocks/StarRocksSinkOperator.java} (74%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/{DorisConstant.java
=> StarRocksConstant.java} (62%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/{DorisLoadNode.java
=> StarRocksLoadNode.java} (60%)