[incubator-inlong] branch master updated (3995800 -> fcec4d9)

[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 3995800  [INLONG-2591][audit] fix the wrong option for script (#2592)
     add fcec4d9  [INLONG-2512] [Manager] Add manager client and optimize some Apis (#2587)

No new revisions were added by this update.

Summary of changes:
 .../pom.xml                                        |  83 +++--
 .../manager/client/api/ClientConfiguration.java}   |  38 ++-
 .../inlong/manager/client/api/DataSeparator.java   |  45 +--
 .../inlong/manager/client/api/DataStream.java      |  13 +-
 .../manager/client/api/DataStreamBuilder.java      |  40 ++-
 .../inlong/manager/client/api/DataStreamConf.java  |  67 ++++
 .../inlong/manager/client/api/DataStreamGroup.java |  73 ++++
 .../manager/client/api/DataStreamGroupConf.java}   |  44 +--
 .../manager/client/api/DataStreamGroupInfo.java    |  84 +++++
 .../manager/client/api/FlinkSortBaseConf.java      |  48 +++
 .../apache/inlong/manager/client/api/HiveSink.java |  95 ++++++
 .../inlong/manager/client/api/InlongClient.java    |  59 ++++
 .../inlong/manager/client/api/MqBaseConf.java}     |  24 +-
 .../inlong/manager/client/api/MySQLSource.java}    |  44 +--
 .../inlong/manager/client/api/PulsarBaseConf.java} |  38 ++-
 .../inlong/manager/client/api/SortBaseConf.java    |  17 +-
 .../inlong/manager/client/api/StreamField.java     |  75 ++++
 .../inlong/manager/client/api/StreamSink.java}     |  18 +-
 .../inlong/manager/client/api/StreamSource.java}   |  24 +-
 .../manager/client/api/auth/Authentication.java}   |  32 +-
 .../client/api/auth/DefaultAuthentication.java}    |  44 +--
 .../client/api/auth/SecretAuthentication.java      |  38 +--
 .../client/api/auth/SecretTokenAuthentication.java |  40 +--
 .../client/api/auth/TokenAuthentication.java       |  26 +-
 .../client/api/impl/DataStreamGroupImpl.java       | 158 +++++++++
 .../manager/client/api/impl/DataStreamImpl.java    |  85 +++++
 .../client/api/impl/DefaultDataStreamBuilder.java  | 103 ++++++
 .../manager/client/api/impl/InlongClientImpl.java  |  78 +++++
 .../client/api/inner/InnerGroupContext.java        |  67 ++++
 .../client/api/inner/InnerInlongManagerClient.java | 377 +++++++++++++++++++++
 .../client/api/inner/InnerStreamContext.java}      |  35 +-
 .../inlong/manager/client/api/util/AssertUtil.java | 176 ++++++++++
 .../client/api/util/DataStreamGroupTransfer.java   | 159 +++++++++
 .../client/api/util/DataStreamTransfer.java        | 160 +++++++++
 .../inlong/manager/client/api/util/GsonUtil.java   | 105 ++++++
 .../manager/client/api/util/InlongParser.java      |  86 +++++
 inlong-manager/manager-common/pom.xml              |   1 -
 .../StorageType.java}                              |  26 +-
 .../manager/common/pojo/business/BusinessInfo.java |   3 +
 .../common/pojo}/workflow/WorkflowResult.java      |   2 +-
 .../manager/common/settings/BusinessSettings.java  |  10 +
 .../inlong/manager/dao/entity/BusinessEntity.java  |   1 +
 .../dao/mapper/BusinessExtEntityMapper.java        |   9 +-
 .../resources/mappers/BusinessEntityMapper.xml     |  20 +-
 .../resources/mappers/BusinessExtEntityMapper.xml  |  16 +-
 .../manager/service/core/ConsumptionService.java   |   2 +-
 .../core/impl/BusinessProcessOperation.java        |   4 +-
 .../service/core/impl/BusinessServiceImpl.java     |  17 +-
 .../service/core/impl/ConsumptionServiceImpl.java  |   2 +-
 .../service/core/impl/DataStreamServiceImpl.java   |   7 +-
 .../manager/service/storage/StorageOperation.java  |   3 +-
 .../service/storage/StorageOperationFactory.java   |   3 +-
 .../service/storage/StorageServiceImpl.java        |  46 +--
 .../service/storage/hive/HiveStorageOperation.java |   5 +-
 .../hive/CreateHiveTableEventSelector.java         |   7 +-
 .../thirdpart/hive/CreateHiveTableListener.java    |   9 +-
 .../thirdpart/sort/ZkSortEventSelector.java        |   6 +-
 .../service/workflow/BaseWorkflowFormType.java     |   3 +
 .../manager/service/workflow/WorkflowService.java  |   1 +
 .../service/workflow/WorkflowServiceImpl.java      |   1 +
 .../business/DeleteBusinessWorkflowDefinition.java |   5 +
 .../RestartBusinessWorkflowDefinition.java         |   5 +
 .../SuspendBusinessWorkflowDefinition.java         |   5 +
 .../listener/BusinessCompleteProcessListener.java  |   7 +-
 .../listener/BusinessFailedProcessListener.java    |   8 +-
 ...ava => UpdateBusinessInfoCompleteListener.java} |  21 +-
 .../core/impl/BusinessProcessOperationTest.java    |   2 +-
 .../service/workflow/WorkflowServiceImplTest.java  |   3 +-
 .../main/resources/sql/apache_inlong_manager.sql   |   7 +-
 .../manager-web/sql/apache_inlong_manager.sql      |   7 +-
 .../manager/web/controller/BusinessController.java |   2 +-
 .../web/controller/ConsumptionController.java      |   2 +-
 .../manager/web/controller/WorkflowController.java |   2 +-
 .../manager/service/core/BusinessServiceTest.java  |   6 +
 inlong-manager/pom.xml                             |  20 +-
 75 files changed, 2610 insertions(+), 394 deletions(-)
 copy inlong-manager/{manager-workflow-engine => manager-client}/pom.xml (54%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/model/view/TaskSummaryView.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/ClientConfiguration.java} (58%)
 copy inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ReportApi.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataSeparator.java (51%)
 copy inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ReadCallback.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStream.java (75%)
 copy inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/repository/MasterRepository.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStreamBuilder.java (56%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStreamConf.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStreamGroup.java
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/commonserver/CommonFileServerListVo.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStreamGroupConf.java} (50%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/DataStreamGroupInfo.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/FlinkSortBaseConf.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/HiveSink.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/ConnectionInfo.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/MqBaseConf.java} (70%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/commonserver/CommonFileServerListVo.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/MySQLSource.java} (56%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/business/BusinessPulsarInfo.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/PulsarBaseConf.java} (67%)
 copy inlong-common/src/main/java/org/apache/inlong/commons/pojo/dataproxy/DataProxyConfig.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/SortBaseConf.java (74%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/StreamField.java
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/agent/ConfirmAgentIpRequest.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/StreamSink.java} (73%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/user/LoginUser.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/StreamSource.java} (71%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/model/definition/ServiceTaskType.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/auth/Authentication.java} (67%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/user/UserDetail.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/auth/DefaultAuthentication.java} (50%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/DefaultMessage.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/auth/SecretAuthentication.java (54%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/DefaultMessage.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/auth/SecretTokenAuthentication.java (52%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/EndMessage.java => inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/auth/TokenAuthentication.java (60%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/DataStreamGroupImpl.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/DataStreamImpl.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/DefaultDataStreamBuilder.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongClientImpl.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerGroupContext.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/pojo/datastream/DataStreamApproveInfo.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerStreamContext.java} (58%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/AssertUtil.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/DataStreamGroupTransfer.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/DataStreamTransfer.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/GsonUtil.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/{model/definition/ServiceTaskType.java => enums/StorageType.java} (64%)
 rename inlong-manager/{manager-service/src/main/java/org/apache/inlong/manager/service => manager-common/src/main/java/org/apache/inlong/manager/common/pojo}/workflow/WorkflowResult.java (97%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/listener/{UpdateBusinessInfoListener.java => UpdateBusinessInfoCompleteListener.java} (75%)