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 501cecb0b [INLONG-7198][Sort] Support audit of Apache Hudi (#7181)
add d6696aff7 [INLONG-7191][DataProxy] Remove unused code (#7192)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/dataproxy/sink/EventStat.java | 81 ---
.../apache/inlong/dataproxy/sink/PulsarSink.java | 725 ---------------------
.../dataproxy/sink/SimpleMessageTubeSink.java | 714 --------------------
.../org/apache/inlong/dataproxy/sink/TubeSink.java | 707 --------------------
.../dataproxy/sink/mqzone/AbstactZoneWorker.java | 108 ---
.../sink/mqzone/AbstractZoneClusterProducer.java | 115 ----
.../sink/mqzone/AbstractZoneProducer.java | 159 -----
.../dataproxy/sink/mqzone/AbstractZoneSink.java | 179 -----
.../sink/mqzone/AbstractZoneSinkContext.java | 405 ------------
.../sink/mqzone/ZoneClusterProducerCalculator.java | 27 -
.../sink/mqzone/ZoneWorkerCalculator.java | 23 -
.../impl/kafkazone/KafkaClusterProducer.java | 148 -----
.../mqzone/impl/kafkazone/KafkaZoneProducer.java | 50 --
.../sink/mqzone/impl/kafkazone/KafkaZoneSink.java | 45 --
.../impl/kafkazone/KafkaZoneSinkContext.java | 44 --
.../mqzone/impl/kafkazone/KafkaZoneWorker.java | 52 --
.../impl/pulsarzone/PulsarClusterProducer.java | 278 --------
.../mqzone/impl/pulsarzone/PulsarZoneProducer.java | 45 --
.../mqzone/impl/pulsarzone/PulsarZoneSink.java | 45 --
.../impl/pulsarzone/PulsarZoneSinkContext.java | 44 --
.../mqzone/impl/pulsarzone/PulsarZoneWorker.java | 52 --
.../mqzone/impl/tubezone/TubeClusterProducer.java | 205 ------
.../mqzone/impl/tubezone/TubeZoneProducer.java | 51 --
.../sink/mqzone/impl/tubezone/TubeZoneSink.java | 46 --
.../mqzone/impl/tubezone/TubeZoneSinkContext.java | 44 --
.../sink/mqzone/impl/tubezone/TubeZoneWorker.java | 51 --
.../sink/pulsar/CreatePulsarClientCallBack.java | 25 -
.../dataproxy/sink/pulsar/PulsarClientService.java | 563 ----------------
.../dataproxy/sink/pulsar/SendMessageCallBack.java | 33 -
.../inlong/dataproxy/sink/pulsar/SinkTask.java | 230 -------
.../pulsar/federation/PulsarFederationSink.java | 140 ----
.../federation/PulsarFederationSinkContext.java | 198 ------
.../pulsar/federation/PulsarFederationWorker.java | 148 -----
.../pulsar/federation/PulsarProducerCluster.java | 319 ---------
.../federation/PulsarProducerFederation.java | 163 -----
.../inlong/dataproxy/sink/TestPulsarSink.java | 56 --
.../apache/inlong/dataproxy/sink/TestTubeSink.java | 57 --
.../federation/TestPulsarFederationSink.java | 87 ---
.../federation/TestPulsarProducerFederation.java | 95 ---
39 files changed, 6557 deletions(-)
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/EventStat.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/PulsarSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/SimpleMessageTubeSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstactZoneWorker.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstractZoneClusterProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstractZoneProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstractZoneSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/AbstractZoneSinkContext.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/ZoneClusterProducerCalculator.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/ZoneWorkerCalculator.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaClusterProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneSinkContext.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/kafkazone/KafkaZoneWorker.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarClusterProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneSinkContext.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/pulsarzone/PulsarZoneWorker.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeClusterProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneProducer.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneSinkContext.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mqzone/impl/tubezone/TubeZoneWorker.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/CreatePulsarClientCallBack.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/SendMessageCallBack.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/SinkTask.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/federation/PulsarFederationSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/federation/PulsarFederationSinkContext.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/federation/PulsarFederationWorker.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/federation/PulsarProducerCluster.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/federation/PulsarProducerFederation.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/sink/TestPulsarSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/sink/TestTubeSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/sink/pulsar/federation/TestPulsarFederationSink.java
delete mode 100644
inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/sink/pulsar/federation/TestPulsarProducerFederation.java
