[incubator-inlong] branch master updated (e0ef7c271 -> 6559c6a18)

[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/incubator-inlong.git


    from e0ef7c271 [INLONG-3868][Sort] Support data from MySQL binlog to Kafka
     add 6559c6a18 [INLONG-3874][Manager] Abstract the operator class for creating Sink resources (#3875)

No new revisions were added by this update.

Summary of changes:
 .../client/api/util/InlongGroupTransfer.java       |  24 +++--
 .../client/api/util/InlongStreamSinkTransfer.java  |  12 ++-
 .../manager/common/enums/GlobalConstants.java      |   2 +-
 .../inlong/manager/common/enums/SinkStatus.java    |   2 +-
 .../manager/common/pojo/sink/SinkExtInfo.java      |  49 ---------
 .../sink/{SinkForSortDTO.java => SinkInfo.java}    |   6 +-
 .../common/pojo/stream/InlongStreamBaseInfo.java   |  35 ------
 .../stream/InlongStreamConfigLogListResponse.java  |  17 ++-
 .../pojo/stream/InlongStreamConfigLogRequest.java  |  14 ++-
 .../common/pojo/stream/InlongStreamInfo.java       |  10 +-
 .../pojo/stream/InlongStreamMetricRequest.java     |  19 ++--
 .../pojo/stream/InlongStreamPageRequest.java       |   2 +-
 .../common/pojo/stream/InlongStreamRequest.java    |  12 ++-
 .../workflow/form/GroupResourceProcessForm.java    |   6 ++
 .../manager/dao/mapper/StreamSinkEntityMapper.java |  12 +--
 .../resources/mappers/StreamSinkEntityMapper.xml   |   9 +-
 .../manager/service/mq/PulsarEventSelector.java    |   3 +-
 ...va => CreateSinkResourceForStreamListener.java} |  49 ++++++---
 ...stener.java => CreateSinkResourceListener.java} |  45 +++++---
 .../service/resource/SinkResourceOperator.java     |  85 +++++++--------
 .../SinkResourceOperatorFactory.java}              |  14 +--
 ...ableOperator.java => HiveResourceOperator.java} |  48 +++++----
 .../service/resource/hive/IHiveTableOperator.java  |  38 -------
 .../service/sink/ck/ClickHouseSinkOperation.java   |   3 +-
 .../service/sink/hive/HiveSinkOperation.java       |   3 +-
 .../service/sink/iceberg/IcebergSinkOperation.java |   3 +-
 .../service/sink/kafka/KafkaSinkOperation.java     |   3 +-
 .../manager/service/utils/SpringContextUtils.java  | 119 ---------------------
 .../workflow/ServiceTaskListenerFactory.java       |   6 +-
 .../listener/StartCreateGroupProcessListener.java  |   7 +-
 .../stream/CreateStreamWorkflowDefinition.java     |   4 +-
 .../service/workflow/WorkflowServiceImplTest.java  |  15 ++-
 .../inlong/manager/web/InLongWebApplication.java   |   6 +-
 .../manager-web/src/main/resources/bean.properties |  20 ----
 34 files changed, 257 insertions(+), 445 deletions(-)
 delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/SinkExtInfo.java
 rename inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{SinkForSortDTO.java => SinkInfo.java} (94%)
 delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/stream/InlongStreamBaseInfo.java
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/{hive/CreateHiveSinkForStreamListener.java => CreateSinkResourceForStreamListener.java} (53%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/{hive/CreateHiveSinkListener.java => CreateSinkResourceListener.java} (52%)
 copy inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/metric/Counting.java => inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/SinkResourceOperator.java (60%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{sink/SinkOperationFactory.java => resource/SinkResourceOperatorFactory.java} (79%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/{DefaultHiveTableOperator.java => HiveResourceOperator.java} (81%)
 delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/IHiveTableOperator.java
 delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/utils/SpringContextUtils.java
 delete mode 100644 inlong-manager/manager-web/src/main/resources/bean.properties