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 72f7726df [INLONG-4510][Manager] Remove GsonUtils, InlongParser, and
Gson dependency (#4511)
add da1bf09c3 [INLONG-4516][Manager] Get the MQ cluster for data proxy
from the inlong cluster table (#4517)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/client/api/InlongClient.java | 6 +-
.../manager/client/api/impl/InlongClientImpl.java | 9 +-
.../common/enums/{MQType.java => ClusterType.java} | 22 +-
.../inlong/manager/common/enums/ErrorCodeEnum.java | 1 +
.../common/pojo/cluster/ClusterPageRequest.java | 53 ----
.../common/pojo/cluster/ClusterRequest.java | 79 ------
.../common/pojo/cluster/ClusterResponse.java | 83 ------
.../pojo/cluster/InlongClusterPageRequest.java | 9 +
.../pulsar/PulsarClusterDTO.java} | 30 +--
...taProxyResponse.java => DataProxyNodeInfo.java} | 13 +-
.../InlongGroupBriefInfo.java} | 25 +-
.../manager/common/pojo/group/InlongGroupInfo.java | 4 +-
.../common/pojo/group/InlongGroupPageRequest.java | 12 +-
.../common/pojo/group/InlongGroupRequest.java | 4 +-
...iefResponse.java => InlongStreamBriefInfo.java} | 12 +-
.../common/pojo/stream/InlongStreamInfo.java | 3 +-
.../pojo/stream/InlongStreamPageRequest.java | 6 +
.../common/pojo/stream/InlongStreamRequest.java | 3 +-
.../common/pojo/stream/InlongStreamResponse.java | 3 +-
.../common/settings/InlongGroupSettings.java | 7 +
.../pojo/transform/TransformDefinitionTest.java | 7 +-
.../dao/mapper/InlongClusterEntityMapper.java | 8 +-
.../dao/mapper/InlongGroupEntityMapper.java | 5 +-
.../dao/mapper/InlongStreamEntityMapper.java | 6 +-
.../mappers/InlongClusterEntityMapper.xml | 27 +-
.../resources/mappers/InlongGroupEntityMapper.xml | 48 ++--
.../resources/mappers/InlongStreamEntityMapper.xml | 15 +-
.../manager/service/CommonOperateService.java | 2 +-
.../manager/service/core/InlongClusterService.java | 25 +-
.../manager/service/core/InlongStreamService.java | 7 +-
.../service/core/impl/ConsumptionServiceImpl.java | 4 +-
.../core/impl/InlongClusterServiceImpl.java | 285 +++++++++------------
.../service/core/impl/InlongStreamServiceImpl.java | 6 +-
.../mq/CreatePulsarResourceTaskListener.java | 8 +-
.../core/impl/InlongClusterServiceTest.java | 17 +-
.../controller/openapi/DataProxyController.java | 31 ++-
36 files changed, 327 insertions(+), 558 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/{MQType.java
=> ClusterType.java} (70%)
delete mode 100644
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/cluster/ClusterPageRequest.java
delete mode 100644
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/cluster/ClusterRequest.java
delete mode 100644
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/cluster/ClusterResponse.java
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{sink/hbase/HBaseColumnFamilyInfo.java
=> cluster/pulsar/PulsarClusterDTO.java} (68%)
rename
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/dataproxy/{DataProxyResponse.java
=> DataProxyNodeInfo.java} (82%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{stream/StreamBriefResponse.java
=> group/InlongGroupBriefInfo.java} (71%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/stream/{StreamBriefResponse.java
=> InlongStreamBriefInfo.java} (82%)
