[incubator-inlong] branch master updated (958c519 -> b1093c6)

[go...@apache.org]

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

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


    from 958c519  [INLONG-1955] Do not set the disabled of the hive field (#1963)
     add b1093c6  [INLONG-1910] inlong sort sdk support consume pulsar events from inlong cachezone (#1956)

No new revisions were added by this update.

Summary of changes:
 {inlong-sort/sort-api => inlong-sdk}/pom.xml       |  37 +-
 inlong-sdk/sort-sdk/pom.xml                        | 117 ++++++
 .../org/apache/inlong/sdk/sort/api/Cleanable.java  |   6 +-
 .../apache/inlong/sdk/sort/api/ClientContext.java  |  38 +-
 .../apache/inlong/sdk/sort/api/EmptyListener.java  |  33 +-
 .../sdk/sort/api/InLongTopicChangeListener.java    |  37 +-
 .../inlong/sdk/sort/api/InLongTopicFetcher.java    |  62 +++
 .../inlong/sdk/sort/api/InLongTopicManager.java    |  46 +++
 .../inlong/sdk/sort/api/InlongTopicTypeEnum.java   |  18 +-
 .../inlong/sdk/sort/api/ManagerReportHandler.java  |  37 +-
 .../inlong/sdk/sort/api/MessageInterceptor.java    |  11 +-
 .../apache/inlong/sdk/sort/api/MetricReporter.java |  10 +-
 .../inlong/sdk/sort/api/QueryConsumeConfig.java    |  11 +-
 .../apache/inlong/sdk/sort/api/ReadCallback.java   |  10 +-
 .../org/apache/inlong/sdk/sort/api/ReportApi.java  |  28 +-
 .../org/apache/inlong/sdk/sort/api/SortClient.java |  13 +-
 .../inlong/sdk/sort/api/SortClientConfig.java      | 244 ++++++++++++
 .../inlong/sdk/sort/api/SortClientFactory.java     |  47 +++
 .../sdk/sort/entity/AcceptAssignmentsParam.java    |  43 +-
 .../inlong/sdk/sort/entity/AssignResult.java       |  39 +-
 .../apache/inlong/sdk/sort/entity/CacheZone.java   | 113 ++++++
 .../inlong/sdk/sort/entity/CacheZoneCluster.java   |  51 ++-
 .../inlong/sdk/sort/entity/CacheZoneConfig.java    |  61 +++
 .../inlong/sdk/sort/entity/ConsumeConfig.java      |  17 +-
 .../inlong/sdk/sort/entity/ConsumeState.java       |  76 ++++
 .../sdk/sort/entity/ConsumeStatusParams.java       |  78 ++++
 .../sdk/sort/entity/ConsumeStatusResult.java       |  33 +-
 .../inlong/sdk/sort/entity/HeartBeatParams.java    |  54 +--
 .../inlong/sdk/sort/entity/HeartBeatResult.java    |  34 +-
 .../apache/inlong/sdk/sort/entity/InLongTopic.java |  94 +++++
 .../inlong/sdk/sort/entity/ManagerResponse.java    |  75 +---
 .../inlong/sdk/sort/entity/MessageRecord.java      |  70 ++++
 .../sdk/sort/entity/RemoveAssignmentsParam.java    |  41 +-
 .../org/apache/inlong/sdk/sort/entity/Topic.java   |  79 ++++
 .../inlong/sdk/sort/entity/UnAssignResult.java     |  57 +++
 .../sort/exception/AlreadyExistTopicException.java |  24 +-
 .../sdk/sort/exception/NotExistException.java      |  21 +-
 .../inlong/sdk/sort/impl/ClientContextImpl.java    |  14 +-
 .../sdk/sort/impl/InLongPulsarFetcherImpl.java     | 224 +++++++++++
 .../sdk/sort/impl/InLongTopicManagerImpl.java      | 362 +++++++++++++++++
 .../sdk/sort/impl/ManagerReportHandlerImpl.java    |  37 +-
 .../inlong/sdk/sort/impl/ManagerReporter.java      | 182 +++++++++
 .../inlong/sdk/sort/impl/MetricReporterImpl.java   |  30 +-
 .../sdk/sort/impl/PulsarMessageListener.java       |  97 +++++
 .../sdk/sort/impl/QueryConsumeConfigImpl.java      | 199 ++++++++++
 .../inlong/sdk/sort/impl/SortClientImpl.java       | 145 +++++++
 .../sdk/sort/stat/SortClientStateCounter.java      | 247 ++++++++++++
 .../apache/inlong/sdk/sort/stat/StatManager.java   | 149 +++++++
 .../apache/inlong/sdk/sort/util/PeriodicTask.java  |  96 +++++
 .../apache/inlong/sdk/sort/util/StringUtil.java    |  98 +++++
 .../sdk/sort/impl/InLongPulsarFetcherImplTest.java | 198 ++++++++++
 .../sdk/sort/impl/InLongTopicManagerImplTest.java  | 151 +++++++
 pom.xml                                            | 434 +++++++++++----------
 53 files changed, 3901 insertions(+), 627 deletions(-)
 copy {inlong-sort/sort-api => inlong-sdk}/pom.xml (63%)
 create mode 100644 inlong-sdk/sort-sdk/pom.xml
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/StorageEsService.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/Cleanable.java (89%)
 copy inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/trigger/CronTrigger.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java (57%)
 copy inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/trigger/CronTrigger.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/EmptyListener.java (60%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/gauge/Gauge.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/InLongTopicChangeListener.java (55%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/InLongTopicFetcher.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/InLongTopicManager.java
 copy inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/entry/TopicStatus.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/InlongTopicTypeEnum.java (74%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/Metrics.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ManagerReportHandler.java (54%)
 copy inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/consts/AttributeConstants.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/MessageInterceptor.java (75%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/AuthenticationType.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/MetricReporter.java (83%)
 copy inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/CityZoneInfo.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/QueryConsumeConfig.java (80%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/AuthenticationType.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ReadCallback.java (81%)
 copy inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/entry/TopicStatus.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ReportApi.java (64%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/tubemq/TubeManagerResponse.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClient.java (75%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientConfig.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/DefaultMessage.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/AcceptAssignmentsParam.java (50%)
 copy inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/trigger/CronTrigger.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/AssignResult.java (58%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/CacheZone.java
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/ColumnQueryBean.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/CacheZoneCluster.java (53%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/CacheZoneConfig.java
 copy inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/utils/ValidateUtils.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/ConsumeConfig.java (70%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/ConsumeState.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/ConsumeStatusParams.java
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/remote/ResponseResult.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/ConsumeStatusResult.java (66%)
 copy inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/entry/MasterEntry.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/HeartBeatParams.java (54%)
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/remote/ResponseResult.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/HeartBeatResult.java (65%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/InLongTopic.java
 copy inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/pojo/SortClusterResponse.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/ManagerResponse.java (51%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/MessageRecord.java
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/DefaultMessage.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/RemoveAssignmentsParam.java (54%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/Topic.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/UnAssignResult.java
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/exceptions/JsonException.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/exception/AlreadyExistTopicException.java (64%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/MetricException.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/exception/NotExistException.java (65%)
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/MetricException.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/ClientContextImpl.java (68%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongPulsarFetcherImpl.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImpl.java
 copy inlong-manager/manager-workflow-engine/src/main/java/org/apache/inlong/manager/workflow/model/definition/ProcessForm.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/ManagerReportHandlerImpl.java (51%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/ManagerReporter.java
 copy inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/Tag.java => inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/MetricReporterImpl.java (63%)
 mode change 100755 => 100644
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/PulsarMessageListener.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/QueryConsumeConfigImpl.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/stat/SortClientStateCounter.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/stat/StatManager.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/util/PeriodicTask.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/util/StringUtil.java
 create mode 100644 inlong-sdk/sort-sdk/src/test/java/org/apache/inlong/sdk/sort/impl/InLongPulsarFetcherImplTest.java
 create mode 100644 inlong-sdk/sort-sdk/src/test/java/org/apache/inlong/sdk/sort/impl/InLongTopicManagerImplTest.java