[incubator-inlong] branch master updated (7fd2b327a -> 5ed020d17)

[he...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


    from 7fd2b327a [INLONG-4247][Manager] Add APIs for create/suspend/restart/delete stream (#4253)
     add 5ed020d17 [INLONG-4197][Manager] Add HBase sink info and load node utils (#4211)

No new revisions were added by this update.

Summary of changes:
 .../api/sink/{KafkaSink.java => HbaseSink.java}    |  47 ++++--
 .../client/api/util/InlongStreamSinkTransfer.java  | 174 ++++++++++++++++++---
 .../inlong/manager/common/enums/SinkType.java      |   3 +-
 .../KafkaSinkDTO.java => hbase/HbaseSinkDTO.java}  |  65 ++++----
 .../HbaseSinkListResponse.java}                    |  38 +++--
 .../HbaseSinkRequest.java}                         |  41 ++---
 .../HbaseSinkResponse.java}                        |  44 +++---
 .../HbaseSinkOperation.java}                       |  68 ++++----
 .../manager/service/sort/util/LoadNodeUtils.java   |  48 ++++++
 ...ceTest.java => HbaseStreamSinkServiceTest.java} |  58 ++++---
 10 files changed, 405 insertions(+), 181 deletions(-)
 copy inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/sink/{KafkaSink.java => HbaseSink.java} (61%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{kafka/KafkaSinkDTO.java => hbase/HbaseSinkDTO.java} (53%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{iceberg/IcebergSinkListResponse.java => hbase/HbaseSinkListResponse.java} (57%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{kafka/KafkaSinkRequest.java => hbase/HbaseSinkRequest.java} (58%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{kafka/KafkaSinkResponse.java => hbase/HbaseSinkResponse.java} (56%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/{kafka/KafkaSinkOperation.java => hbase/HbaseSinkOperation.java} (82%)
 copy inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/{KafkaStreamSinkServiceTest.java => HbaseStreamSinkServiceTest.java} (62%)