You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ji...@apache.org on 2019/11/20 18:05:04 UTC

[incubator-druid] branch master updated (ee8f048 -> d628beb)

This is an automated email from the ASF dual-hosted git repository.

jihoonson pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.


    from ee8f048  Web console: rename Tasks to Ingestion (#8896)
     add d628beb  Make supervisor API similar to submit task API (#8810)

No new revisions were added by this update.

Summary of changes:
 docs/tutorials/tutorial-kafka.md                   | 104 +++++++++----------
 .../tutorial/wikipedia-kafka-supervisor.json       | 113 +++++++++++----------
 .../supervisor/KafkaSupervisorIngestionSpec.java   |  28 ++---
 .../kafka/supervisor/KafkaSupervisorSpec.java      |  55 +++++-----
 .../supervisor/KafkaSupervisorTuningConfig.java    |  30 ++++++
 .../druid/indexing/kafka/KafkaSamplerSpecTest.java |   1 +
 .../kafka/supervisor/KafkaSupervisorSpecTest.java  |  85 ++++++++++++++++
 .../kafka/supervisor/KafkaSupervisorTest.java      |   3 +
 .../supervisor/KinesisSupervisorIngestionSpec.java |  29 +++---
 .../kinesis/supervisor/KinesisSupervisorSpec.java  |  62 +++++------
 .../supervisor/KinesisSupervisorTuningConfig.java  |  37 +++++++
 .../indexing/kinesis/KinesisSamplerSpecTest.java   |   1 +
 .../kinesis/supervisor/KinesisSupervisorTest.java  |   4 +
 .../SeekableStreamSupervisorIngestionSpec.java     |  21 ++--
 .../supervisor/SeekableStreamSupervisorSpec.java   |  39 ++++---
 15 files changed, 390 insertions(+), 222 deletions(-)
 copy server/src/main/java/org/apache/druid/segment/indexing/IngestionSpec.java => extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorIngestionSpec.java (60%)
 copy server/src/main/java/org/apache/druid/segment/indexing/IngestionSpec.java => extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorIngestionSpec.java (59%)
 copy server/src/main/java/org/apache/druid/segment/indexing/IngestionSpec.java => indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIngestionSpec.java (68%)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org