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/inlong.git
from 56263c334 [INLONG-7054][DataProxy] Add the processing of the rtms
field (#7055)
add a75634761 [INLONG-6945][SDK] Unify metrics report model of SortSDK
(#6954)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/sdk/sort/api/ClientContext.java | 133 +++++++--
.../inlong/sdk/sort/api/ConfigConstants.java | 2 +
.../inlong/sdk/sort/api/ManagerReportHandler.java | 43 ---
.../apache/inlong/sdk/sort/api/MetricReporter.java | 25 --
.../inlong/sdk/sort/api/SortClientConfig.java | 21 +-
.../inlong/sdk/sort/api/SortClientFactory.java | 10 +-
.../fetcher/kafka/KafkaMultiTopicsFetcher.java | 33 +--
.../fetcher/kafka/KafkaSingleTopicFetcher.java | 29 +-
.../fetcher/pulsar/PulsarMultiTopicsFetcher.java | 40 +--
.../fetcher/pulsar/PulsarSingleTopicFetcher.java | 38 +--
.../sort/fetcher/tube/TubeSingleTopicFetcher.java | 35 +--
.../inlong/sdk/sort/impl/ClientContextImpl.java | 5 +-
.../sdk/sort/impl/ManagerReportHandlerImpl.java | 49 ----
.../inlong/sdk/sort/impl/ManagerReporter.java | 182 -------------
.../inlong/sdk/sort/impl/MetricReporterImpl.java | 108 --------
.../sdk/sort/impl/QueryConsumeConfigImpl.java | 9 +-
.../inlong/sdk/sort/impl/SortClientImpl.java | 11 +-
.../sdk/sort/impl/decode/MessageDeserializer.java | 12 -
.../sdk/sort/manager/InlongMultiTopicManager.java | 9 +-
.../sdk/sort/manager/InlongSingleTopicManager.java | 19 +-
.../inlong/sdk/sort/metrics/SortSdkMetricItem.java | 20 +-
.../sdk/sort/metrics/SortSdkMetricItemSet.java | 30 ++-
.../metrics/SortSdkPrometheusMetricListener.java | 78 +++++-
.../sdk/sort/stat/SortClientStateCounter.java | 300 ---------------------
.../apache/inlong/sdk/sort/stat/StatManager.java | 149 ----------
.../standalone/source/sortsdk/SortSdkSource.java | 12 +-
26 files changed, 369 insertions(+), 1033 deletions(-)
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ManagerReportHandler.java
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/MetricReporter.java
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/ManagerReportHandlerImpl.java
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/ManagerReporter.java
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/MetricReporterImpl.java
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/AgentMetricItemSet.java
=>
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/metrics/SortSdkMetricItemSet.java
(66%)
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/stat/SortClientStateCounter.java
delete mode 100644
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/stat/StatManager.java
