You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2020/11/11 06:54:39 UTC
[pulsar] branch master updated (dafa7e0 -> eb44a75)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from dafa7e0 [Transaction]Transaction pendingack server implement patch (#8426)
add eb44a75 PIP-62: Remove tests and examples related to pulsar-adapters (#8511)
No new revisions were added by this update.
Summary of changes:
examples/flink/pom.xml | 165 ----
.../example/FlinkPulsarBatchAvroSinkExample.java | 89 ---
.../example/FlinkPulsarBatchCsvSinkExample.java | 100 ---
.../example/FlinkPulsarBatchJsonSinkExample.java | 124 ---
.../example/FlinkPulsarBatchSinkExample.java | 128 ---
.../batch/connectors/pulsar/example/README.md | 220 -----
.../example/PulsarConsumerSourceWordCount.java | 128 ---
...lsarConsumerSourceWordCountToAvroTableSink.java | 121 ---
...lsarConsumerSourceWordCountToJsonTableSink.java | 134 ----
.../streaming/connectors/pulsar/example/README.md | 209 -----
.../flink/src/main/resources/avro/NasaMission.avsc | 20 -
examples/flink/src/main/resources/log4j2.xml | 37 -
.../FlinkPulsarBatchAvroSinkScalaExample.scala | 88 --
.../FlinkPulsarBatchCsvSinkScalaExample.scala | 94 ---
.../FlinkPulsarBatchJsonSinkScalaExample.scala | 96 ---
.../example/FlinkPulsarBatchSinkScalaExample.scala | 102 ---
examples/pom.xml | 40 -
examples/spark/pom.xml | 118 ---
.../example/ProducerSparkReceiverData.java | 55 --
.../receiver/example/ProducerSparkWithPojo.java | 61 --
.../spark/streaming/receiver/example/README.md | 107 ---
.../streaming/receiver/example/SensorReading.java | 53 --
.../SparkStreamingPulsarReceiverExample.java | 90 ---
pom.xml | 5 -
tests/pom.xml | 3 -
tests/pulsar-kafka-compat-client-test/pom.xml | 127 ---
.../integration/compat/kafka/KafkaApiTest.java | 885 ---------------------
.../kafka/PulsarKafkaProducerThreadSafeTest.java | 60 --
tests/pulsar-spark-test/pom.xml | 119 ---
.../spark/SparkStreamingPulsarReceiverTest.java | 162 ----
tests/pulsar-storm-test/pom.xml | 119 ---
.../apache/pulsar/storm/MockOutputCollector.java | 101 ---
.../pulsar/storm/MockSpoutOutputCollector.java | 80 --
.../org/apache/pulsar/storm/PulsarBoltTest.java | 238 ------
.../org/apache/pulsar/storm/PulsarSpoutTest.java | 349 --------
.../java/org/apache/pulsar/storm/TestUtil.java | 35 -
.../apache/pulsar/storm/example/StormExample.java | 166 ----
37 files changed, 4828 deletions(-)
delete mode 100644 examples/flink/pom.xml
delete mode 100644 examples/flink/src/main/java/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchAvroSinkExample.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchCsvSinkExample.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchJsonSinkExample.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchSinkExample.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/batch/connectors/pulsar/example/README.md
delete mode 100644 examples/flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/example/PulsarConsumerSourceWordCount.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/example/PulsarConsumerSourceWordCountToAvroTableSink.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/example/PulsarConsumerSourceWordCountToJsonTableSink.java
delete mode 100644 examples/flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/example/README.md
delete mode 100644 examples/flink/src/main/resources/avro/NasaMission.avsc
delete mode 100644 examples/flink/src/main/resources/log4j2.xml
delete mode 100644 examples/flink/src/main/scala/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchAvroSinkScalaExample.scala
delete mode 100644 examples/flink/src/main/scala/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchCsvSinkScalaExample.scala
delete mode 100644 examples/flink/src/main/scala/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchJsonSinkScalaExample.scala
delete mode 100644 examples/flink/src/main/scala/org/apache/flink/batch/connectors/pulsar/example/FlinkPulsarBatchSinkScalaExample.scala
delete mode 100644 examples/pom.xml
delete mode 100644 examples/spark/pom.xml
delete mode 100644 examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/ProducerSparkReceiverData.java
delete mode 100644 examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/ProducerSparkWithPojo.java
delete mode 100644 examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/README.md
delete mode 100644 examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SensorReading.java
delete mode 100644 examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiverExample.java
delete mode 100644 tests/pulsar-kafka-compat-client-test/pom.xml
delete mode 100644 tests/pulsar-kafka-compat-client-test/src/test/java/org/apache/pulsar/tests/integration/compat/kafka/KafkaApiTest.java
delete mode 100644 tests/pulsar-kafka-compat-client-test/src/test/java/org/apache/pulsar/tests/integration/compat/kafka/PulsarKafkaProducerThreadSafeTest.java
delete mode 100644 tests/pulsar-spark-test/pom.xml
delete mode 100644 tests/pulsar-spark-test/src/test/java/org/apache/pulsar/spark/SparkStreamingPulsarReceiverTest.java
delete mode 100644 tests/pulsar-storm-test/pom.xml
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/MockOutputCollector.java
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/MockSpoutOutputCollector.java
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/PulsarBoltTest.java
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/TestUtil.java
delete mode 100644 tests/pulsar-storm-test/src/test/java/org/apache/pulsar/storm/example/StormExample.java