This is an automated email from the ASF dual-hosted git repository.
fjy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from 613f09b SQL: Add TIME_CEIL function. (#8027)
add 42a7b88 remove FirehoseV2 and realtime node extensions (#8020)
No new revisions were added by this update.
Summary of changes:
LICENSE.BINARY | 47 --
NOTICE.BINARY | 38 --
.../apache/druid/data/input/FirehoseFactoryV2.java | 51 --
.../org/apache/druid/data/input/FirehoseV2.java | 91 ----
distribution/pom.xml | 10 -
docs/_redirects.json | 8 +-
.../development/extensions-contrib/kafka-simple.md | 56 --
.../development/extensions-contrib/rabbitmq.md | 81 ---
.../development/extensions-contrib/rocketmq.md | 29 -
.../extensions-core/kafka-eight-firehose.md | 54 --
docs/content/development/extensions.md | 4 -
docs/content/ingestion/standalone-realtime.md | 3 +
docs/content/operations/pull-deps.md | 17 +-
examples/pom.xml | 134 -----
.../apache/druid/examples/ExamplesDruidModule.java | 56 --
.../twitter/TwitterSpritzerFirehoseFactory.java | 387 --------------
.../druid/examples/wikipedia/IrcDecoder.java | 34 --
.../examples/wikipedia/IrcFirehoseFactory.java | 256 ---------
.../examples/wikipedia/IrcInputRowParser.java | 107 ----
.../examples/wikipedia/WikipediaIrcDecoder.java | 307 -----------
.../org.apache.druid.initialization.DruidModule | 16 -
extensions-contrib/druid-rocketmq/pom.xml | 58 --
.../firehose/rocketmq/RocketMQDruidModule.java | 50 --
.../firehose/rocketmq/RocketMQFirehoseFactory.java | 584 ---------------------
.../kafka-eight-simpleConsumer/pom.xml | 89 ----
.../kafka/KafkaEightSimpleConsumerDruidModule.java | 49 --
.../KafkaEightSimpleConsumerFirehoseFactory.java | 350 ------------
.../druid/firehose/kafka/KafkaSimpleConsumer.java | 390 --------------
.../org.apache.druid.initialization.DruidModule | 16 -
extensions-contrib/rabbitmq/pom.xml | 83 ---
.../rabbitmq/JacksonifiedConnectionFactory.java | 280 ----------
.../firehose/rabbitmq/RabbitMQDruidModule.java | 51 --
.../firehose/rabbitmq/RabbitMQFirehoseConfig.java | 186 -------
.../firehose/rabbitmq/RabbitMQFirehoseFactory.java | 339 ------------
.../org.apache.druid.initialization.DruidModule | 16 -
.../rabbitmq/RabbitMQFirehoseFactoryTest.java | 111 ----
.../examples/rabbitmq/RabbitMQProducerMain.java | 212 --------
extensions-core/kafka-eight/pom.xml | 75 ---
.../firehose/kafka/KafkaEightDruidModule.java | 52 --
.../firehose/kafka/KafkaEightFirehoseFactory.java | 176 -------
.../org.apache.druid.initialization.DruidModule | 16 -
.../kafka/supervisor/KafkaSupervisorTest.java | 2 +-
.../kinesis/supervisor/KinesisSupervisorTest.java | 2 +-
.../task/AppenderatorDriverRealtimeIndexTask.java | 2 +-
.../druid/indexing/common/task/IndexTask.java | 2 +-
.../task/batch/parallel/ParallelIndexSubTask.java | 2 +-
.../SeekableStreamIndexTaskRunner.java | 2 +-
.../druid/indexing/common/TestRealtimeTask.java | 3 +-
.../AppenderatorDriverRealtimeIndexTaskTest.java | 1 -
.../common/task/RealtimeIndexTaskTest.java | 1 -
.../druid/indexing/common/task/TaskSerdeTest.java | 3 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 3 +-
.../indexing/worker/TaskAnnouncementTest.java | 3 +-
pom.xml | 6 +-
.../druid/segment/indexing/RealtimeIOConfig.java | 16 +-
.../druid/segment/realtime/FireDepartment.java | 11 -
.../druid/segment/realtime/plumber/Committers.java | 13 -
.../druid/initialization/InitializationTest.java | 14 +-
.../druid/segment/realtime/FireDepartmentTest.java | 3 +-
.../druid/cli/validate/DruidJsonValidatorTest.java | 3 +-
60 files changed, 31 insertions(+), 5030 deletions(-)
delete mode 100644
core/src/main/java/org/apache/druid/data/input/FirehoseFactoryV2.java
delete mode 100644
core/src/main/java/org/apache/druid/data/input/FirehoseV2.java
delete mode 100644 docs/content/development/extensions-contrib/kafka-simple.md
delete mode 100644 docs/content/development/extensions-contrib/rabbitmq.md
delete mode 100644 docs/content/development/extensions-contrib/rocketmq.md
delete mode 100644
docs/content/development/extensions-core/kafka-eight-firehose.md
delete mode 100644 examples/pom.xml
delete mode 100644
examples/src/main/java/org/apache/druid/examples/ExamplesDruidModule.java
delete mode 100644
examples/src/main/java/org/apache/druid/examples/twitter/TwitterSpritzerFirehoseFactory.java
delete mode 100644
examples/src/main/java/org/apache/druid/examples/wikipedia/IrcDecoder.java
delete mode 100644
examples/src/main/java/org/apache/druid/examples/wikipedia/IrcFirehoseFactory.java
delete mode 100644
examples/src/main/java/org/apache/druid/examples/wikipedia/IrcInputRowParser.java
delete mode 100644
examples/src/main/java/org/apache/druid/examples/wikipedia/WikipediaIrcDecoder.java
delete mode 100644
examples/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
delete mode 100644 extensions-contrib/druid-rocketmq/pom.xml
delete mode 100644
extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQDruidModule.java
delete mode 100644
extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQFirehoseFactory.java
delete mode 100644 extensions-contrib/kafka-eight-simpleConsumer/pom.xml
delete mode 100644
extensions-contrib/kafka-eight-simpleConsumer/src/main/java/org/apache/druid/firehose/kafka/KafkaEightSimpleConsumerDruidModule.java
delete mode 100644
extensions-contrib/kafka-eight-simpleConsumer/src/main/java/org/apache/druid/firehose/kafka/KafkaEightSimpleConsumerFirehoseFactory.java
delete mode 100644
extensions-contrib/kafka-eight-simpleConsumer/src/main/java/org/apache/druid/firehose/kafka/KafkaSimpleConsumer.java
delete mode 100644
extensions-contrib/kafka-eight-simpleConsumer/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
delete mode 100644 extensions-contrib/rabbitmq/pom.xml
delete mode 100644
extensions-contrib/rabbitmq/src/main/java/org/apache/druid/firehose/rabbitmq/JacksonifiedConnectionFactory.java
delete mode 100644
extensions-contrib/rabbitmq/src/main/java/org/apache/druid/firehose/rabbitmq/RabbitMQDruidModule.java
delete mode 100644
extensions-contrib/rabbitmq/src/main/java/org/apache/druid/firehose/rabbitmq/RabbitMQFirehoseConfig.java
delete mode 100644
extensions-contrib/rabbitmq/src/main/java/org/apache/druid/firehose/rabbitmq/RabbitMQFirehoseFactory.java
delete mode 100644
extensions-contrib/rabbitmq/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
delete mode 100644
extensions-contrib/rabbitmq/src/test/java/org/apache/druid/examples/rabbitmq/RabbitMQFirehoseFactoryTest.java
delete mode 100644
extensions-contrib/rabbitmq/src/test/java/org/apache/druid/examples/rabbitmq/RabbitMQProducerMain.java
delete mode 100644 extensions-core/kafka-eight/pom.xml
delete mode 100644
extensions-core/kafka-eight/src/main/java/org/apache/druid/firehose/kafka/KafkaEightDruidModule.java
delete mode 100644
extensions-core/kafka-eight/src/main/java/org/apache/druid/firehose/kafka/KafkaEightFirehoseFactory.java
delete mode 100644
extensions-core/kafka-eight/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
