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 5db0eb8bd [INLONG-4217][TubeMQ] Add flow control and filtering methods
to the consumption group settings (#4230)
add 0a0814129 [INLONG-4220][Manager] Add StreamResourceProcessForm (#4234)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/StreamStatus.java | 10 +-
.../common/pojo/stream/InlongStreamInfo.java | 3 +
.../common/pojo/workflow/form/BaseProcessForm.java | 1 +
...essForm.java => StreamResourceProcessForm.java} | 14 +--
.../service/core/impl/InlongGroupServiceImpl.java | 2 +-
.../core/impl/InlongStreamProcessOperation.java | 60 +++++++++
.../service/core/impl/InlongStreamServiceImpl.java | 3 +-
.../service/mq/CreatePulsarGroupTaskListener.java | 1 +
.../mq/CreatePulsarResourceTaskListener.java | 3 +-
...a => CreatePulsarSubscriptionTaskListener.java} | 46 +++----
...ner.java => CreatePulsarTopicTaskListener.java} | 31 ++---
.../service/mq/CreateTubeGroupTaskListener.java | 1 +
.../service/mq/CreateTubeTopicTaskListener.java | 1 +
...EventSelector.java => PulsarTopicSelector.java} | 26 ++--
.../service/mq/{ => util}/PulsarOptService.java | 2 +-
.../mq/{ => util}/PulsarOptServiceImpl.java | 3 +-
.../service/mq/{ => util}/TubeMqOptService.java | 2 +-
...stener.java => StreamSinkResourceListener.java} | 40 +++---
.../service/sink/StreamSinkServiceImpl.java | 63 +---------
.../service/sort/CreateSortConfigListener.java | 28 +----
...er.java => CreateStreamSortConfigListener.java} | 72 ++++-------
.../service/sort/PushSortConfigListener.java | 41 ------
.../service/sort/ZookeeperDisabledSelector.java | 15 ++-
.../service/sort/ZookeeperEnabledSelector.java | 2 -
.../listener/AbstractSourceOperateListener.java | 2 +-
.../manager/service/workflow/ProcessName.java | 21 +++-
.../ConsumptionCompleteProcessListener.java | 4 +-
.../group/CreateGroupWorkflowDefinition.java | 12 +-
.../group/DeleteGroupWorkflowDefinition.java | 8 +-
.../group/RestartGroupWorkflowDefinition.java | 8 +-
.../group/SuspendGroupWorkflowDefinition.java | 8 +-
.../light/CreateLightGroupWorkflowDefinition.java | 6 +-
.../light/DeleteLightGroupWorkflowDefinition.java | 6 +-
.../light/RestartLightGroupWorkflowDefinition.java | 6 +-
.../light/SuspendLightGroupWorkflowDefinition.java | 6 +-
.../group/listener/GroupCancelProcessListener.java | 2 +-
.../listener/GroupCompleteProcessListener.java | 2 +-
.../group/listener/GroupFailedProcessListener.java | 2 +-
.../group/listener/GroupInitProcessListener.java | 2 +-
.../listener/GroupUpdateCompleteListener.java | 6 +-
.../group/listener/GroupUpdateFailedListener.java | 6 +-
.../group/listener/GroupUpdateListener.java | 2 +-
.../approve/GroupAfterApprovedListener.java | 4 +-
.../approve/GroupApproveProcessListener.java | 4 +-
.../approve/GroupRejectProcessListener.java | 2 +-
.../listener/light/LightGroupCompleteListener.java | 2 +-
.../listener/light/LightGroupFailedListener.java | 2 +-
.../listener/light/LightGroupInitListener.java | 2 +-
.../light/LightGroupUpdateCompleteListener.java | 2 +-
.../light/LightGroupUpdateFailedListener.java | 2 +-
.../listener/light/LightGroupUpdateListener.java | 2 +-
.../GroupTaskListenerFactory.java} | 11 +-
.../StreamTaskListenerFactory.java} | 112 +++++++----------
.../stream/CreateStreamWorkflowDefinition.java | 137 ++++++++-------------
.../DeleteStreamWorkflowDefinition.java} | 45 ++++---
.../RestartStreamWorkflowDefinition.java} | 48 ++++----
.../SuspendStreamWorkflowDefinition.java} | 48 ++++----
.../StreamCompleteProcessListener.java | 24 ++--
.../StreamFailedProcessListener.java | 20 ++-
.../StreamInitProcessListener.java} | 28 +++--
.../listener/StreamUpdateCompleteListener.java} | 40 +++---
.../listener/StreamUpdateFailedListener.java} | 30 ++---
.../listener/StreamUpdateListener.java} | 44 +++----
.../core/impl/InlongGroupProcessOperationTest.java | 6 +-
...Test.java => GroupTaskListenerFactoryTest.java} | 9 +-
.../service/workflow/WorkflowServiceImplTest.java | 3 +-
.../inlong/manager/workflow/WorkflowContext.java | 10 +-
.../core/impl/WorkflowContextBuilderImpl.java | 6 +-
.../workflow/processor/StartEventProcessor.java | 2 +-
.../manager/workflow/util/WorkflowBeanUtils.java | 2 +-
70 files changed, 528 insertions(+), 698 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/workflow/form/{LightGroupResourceProcessForm.java
=> StreamResourceProcessForm.java} (77%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/InlongStreamProcessOperation.java
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{CreatePulsarGroupForStreamTaskListener.java
=> CreatePulsarSubscriptionTaskListener.java} (78%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{CreatePulsarTopicForStreamTaskListener.java
=> CreatePulsarTopicTaskListener.java} (79%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{TubeEventSelector.java
=> PulsarTopicSelector.java} (60%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{
=> util}/PulsarOptService.java (97%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{
=> util}/PulsarOptServiceImpl.java (99%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/mq/{
=> util}/TubeMqOptService.java (99%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/{CreateSinkResourceForStreamListener.java
=> StreamSinkResourceListener.java} (65%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/{CreateSortConfigListener.java
=> CreateStreamSortConfigListener.java} (59%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{ServiceTaskListenerFactory.java
=> listener/GroupTaskListenerFactory.java} (95%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{ServiceTaskListenerFactory.java
=> listener/StreamTaskListenerFactory.java} (61%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/DeleteGroupWorkflowDefinition.java
=> stream/DeleteStreamWorkflowDefinition.java} (65%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/RestartGroupWorkflowDefinition.java
=> stream/RestartStreamWorkflowDefinition.java} (65%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/SuspendGroupWorkflowDefinition.java
=> stream/SuspendStreamWorkflowDefinition.java} (65%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/stream/{
=> listener}/StreamCompleteProcessListener.java (76%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/stream/{
=> listener}/StreamFailedProcessListener.java (76%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/stream/{InitGroupForStreamListener.java
=> listener/StreamInitProcessListener.java} (62%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/listener/GroupUpdateCompleteListener.java
=> stream/listener/StreamUpdateCompleteListener.java} (61%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/listener/light/LightGroupFailedListener.java
=> stream/listener/StreamUpdateFailedListener.java} (61%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{group/listener/light/LightGroupUpdateListener.java
=> stream/listener/StreamUpdateListener.java} (56%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/{ServiceTaskListenerFactoryTest.java
=> GroupTaskListenerFactoryTest.java} (87%)
