You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/09/06 01:58:56 UTC
[inlong] branch master updated (e366be227 -> 4d7b59928)
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 e366be227 [INLONG-5666][Sort] Supports init multiple Sort SDK to improve performance (#5684)
add 4d7b59928 [INLONG-4962][DataProxy] Unify the MQ zone sink (#5323)
No new revisions were added by this update.
Summary of changes:
.../inlong/dataproxy/consts/ConfigConstants.java | 22 ++
.../inlong/dataproxy/dispatch/DispatchManager.java | 44 ++-
.../inlong/dataproxy/dispatch/DispatchProfile.java | 17 ++
.../apache/inlong/dataproxy/sink/SinkContext.java | 186 ------------
.../sink/kafkazone/KafkaZoneProducer.java | 163 ----------
.../dataproxy/sink/kafkazone/KafkaZoneSink.java | 166 ----------
.../sink/kafkazone/KafkaZoneSinkContext.java | 264 ----------------
.../dataproxy/sink/kafkazone/KafkaZoneWorker.java | 107 -------
.../AbstactZoneWorker.java} | 32 +-
.../sink/mqzone/AbstractZoneClusterProducer.java | 115 +++++++
.../AbstractZoneProducer.java} | 55 ++--
.../AbstractZoneSink.java} | 95 +++---
.../AbstractZoneSinkContext.java} | 338 +++++++++++++++------
.../mqzone/ZoneClusterProducerCalculator.java} | 15 +-
.../sink/mqzone/ZoneWorkerCalculator.java | 10 +-
.../impl}/kafkazone/KafkaClusterProducer.java | 88 +-----
.../mqzone/impl/kafkazone/KafkaZoneProducer.java | 49 +++
.../sink/mqzone/impl/kafkazone/KafkaZoneSink.java | 37 ++-
.../impl/kafkazone/KafkaZoneSinkContext.java} | 33 +-
.../mqzone/impl/kafkazone/KafkaZoneWorker.java} | 54 ++--
.../impl}/pulsarzone/PulsarClusterProducer.java | 148 +++------
.../mqzone/impl/pulsarzone/PulsarZoneProducer.java | 45 +++
.../mqzone/impl/pulsarzone/PulsarZoneSink.java | 37 ++-
.../impl/pulsarzone/PulsarZoneSinkContext.java} | 33 +-
.../mqzone/impl/pulsarzone/PulsarZoneWorker.java} | 54 ++--
.../impl}/tubezone/TubeClusterProducer.java | 92 +-----
.../mqzone/impl/tubezone/TubeZoneProducer.java | 50 +++
.../sink/mqzone/impl/tubezone/TubeZoneSink.java | 38 ++-
.../mqzone/impl/tubezone/TubeZoneSinkContext.java} | 34 +--
.../mqzone/impl/tubezone/TubeZoneWorker.java} | 34 ++-
.../sink/pulsarzone/PulsarZoneWorker.java | 107 -------
.../dataproxy/sink/tubezone/TubeZoneProducer.java | 162 ----------
.../dataproxy/sink/tubezone/TubeZoneSink.java | 166 ----------
.../sink/tubezone/TubeZoneSinkContext.java | 264 ----------------
34 files changed, 879 insertions(+), 2275 deletions(-)
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/SinkContext.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/kafkazone/KafkaZoneProducer.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/kafkazone/KafkaZoneSink.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/kafkazone/KafkaZoneSinkContext.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/kafkazone/KafkaZoneWorker.java
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{tubezone/TubeZoneWorker.java => mqzone/AbstactZoneWorker.java} (78%)
create mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstractZoneClusterProducer.java
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{pulsarzone/PulsarZoneProducer.java => mqzone/AbstractZoneProducer.java} (73%)
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{pulsarzone/PulsarZoneSink.java => mqzone/AbstractZoneSink.java} (64%)
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{pulsarzone/PulsarZoneSinkContext.java => mqzone/AbstractZoneSinkContext.java} (60%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{config/loader/CacheClusterConfigLoader.java => sink/mqzone/ZoneClusterProducerCalculator.java} (70%)
copy inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/MessageSentCallback.java => inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/ZoneWorkerCalculator.java (80%)
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{ => mqzone/impl}/kafkazone/KafkaClusterProducer.java (61%)
create mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneProducer.java
copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/simplemvc/ControlTool.java => inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneSink.java (54%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{metrics/DataProxyMetricItemSet.java => sink/mqzone/impl/kafkazone/KafkaZoneSinkContext.java} (55%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{config/pojo/CacheType.java => sink/mqzone/impl/kafkazone/KafkaZoneWorker.java} (53%)
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{ => mqzone/impl}/pulsarzone/PulsarClusterProducer.java (61%)
create mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneProducer.java
copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/simplemvc/ControlTool.java => inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneSink.java (54%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{metrics/DataProxyMetricItemSet.java => sink/mqzone/impl/pulsarzone/PulsarZoneSinkContext.java} (55%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{config/pojo/CacheType.java => sink/mqzone/impl/pulsarzone/PulsarZoneWorker.java} (53%)
rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/{ => mqzone/impl}/tubezone/TubeClusterProducer.java (70%)
create mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneProducer.java
copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/simplemvc/ControlTool.java => inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneSink.java (54%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{metrics/DataProxyMetricItemSet.java => sink/mqzone/impl/tubezone/TubeZoneSinkContext.java} (55%)
copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/{metrics/DataProxyMetricItemSet.java => sink/mqzone/impl/tubezone/TubeZoneWorker.java} (53%)
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsarzone/PulsarZoneWorker.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeZoneProducer.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeZoneSink.java
delete mode 100644 inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/tubezone/TubeZoneSinkContext.java