This is an automated email from the ASF dual-hosted git repository.
amatya pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 59bb72a9268 Fix parsing of env variables when properties have
underscores (#15919)
add 80942d5754d Feature: add support for ingesting from rabbitmq super
streams (#14137)
No new revisions were added by this update.
Summary of changes:
distribution/pom.xml | 2 +
docs/ingestion/rabbit-stream-ingestion.md | 239 +++++++++
.../rabbit-stream-indexing-service/pom.xml | 178 ++++++
...entalPublishingRabbitStreamIndexTaskRunner.java | 158 ++++++
.../rabbitstream/RabbitSequenceNumber.java | 47 ++
.../RabbitStreamDataSourceMetadata.java | 57 ++
.../rabbitstream/RabbitStreamIndexTask.java | 150 ++++++
.../RabbitStreamIndexTaskClientFactory.java | 52 ++
.../RabbitStreamIndexTaskIOConfig.java | 118 ++++
.../rabbitstream/RabbitStreamIndexTaskModule.java | 58 ++
.../RabbitStreamIndexTaskTuningConfig.java | 259 +++++++++
.../rabbitstream/RabbitStreamRecordSupplier.java | 481 +++++++++++++++++
.../rabbitstream/RabbitStreamSamplerSpec.java | 72 +++
.../supervisor/RabbitStreamSupervisor.java | 420 +++++++++++++++
.../supervisor/RabbitStreamSupervisorIOConfig.java | 142 +++++
.../RabbitStreamSupervisorIngestionSpec.java | 65 +++
.../RabbitStreamSupervisorReportPayload.java | 90 ++++
.../supervisor/RabbitStreamSupervisorSpec.java | 167 ++++++
.../RabbitStreamSupervisorTuningConfig.java | 254 +++++++++
.../org.apache.druid.initialization.DruidModule | 16 +
.../RabbitStreamIndexTaskIOConfigTest.java | 88 +++
.../RabbitStreamIndexTaskTuningConfigTest.java | 182 +++++++
.../RabbitStreamRecordSupplierTest.java | 597 +++++++++++++++++++++
.../RabbitStreamSupervisorIOConfigTest.java | 139 +++++
.../supervisor/RabbitStreamSupervisorTest.java | 369 +++++++++++++
.../RabbitStreamSupervisorTuningConfigTest.java | 126 +++++
licenses.yaml | 10 +
pom.xml | 1 +
website/.spelling | 1 +
29 files changed, 4538 insertions(+)
create mode 100644 docs/ingestion/rabbit-stream-ingestion.md
create mode 100644 extensions-contrib/rabbit-stream-indexing-service/pom.xml
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/IncrementalPublishingRabbitStreamIndexTaskRunner.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitSequenceNumber.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamDataSourceMetadata.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTask.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskClientFactory.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskIOConfig.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskModule.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskTuningConfig.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamRecordSupplier.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/RabbitStreamSamplerSpec.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisor.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorIOConfig.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorIngestionSpec.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorReportPayload.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorSpec.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorTuningConfig.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskIOConfigTest.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/RabbitStreamIndexTaskTuningConfigTest.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/RabbitStreamRecordSupplierTest.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorIOConfigTest.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorTest.java
create mode 100644
extensions-contrib/rabbit-stream-indexing-service/src/test/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamSupervisorTuningConfigTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
