This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from f037776fd8 MSQ: Launch initial tasks faster. (#13393)
add bfffbabb56 Async task client for SeekableStreamSupervisors. (#13354)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/common/guava/FutureUtils.java | 55 ++
.../org/apache/druid/java/util/common/Either.java | 12 +-
.../java/util/common/jackson/JacksonUtils.java | 31 +-
.../apache/druid/common/guava/FutureUtilsTest.java | 104 ++++
.../druid/common/jackson/JacksonUtilsTest.java | 29 +
.../extensions-core/kafka-supervisor-reference.md | 3 +-
.../extensions-core/kinesis-ingestion.md | 3 +-
.../druid/indexing/kafka/KafkaIndexTaskClient.java | 62 --
.../kafka/KafkaIndexTaskClientFactory.java | 34 +-
.../druid/indexing/kafka/KafkaIndexTaskModule.java | 9 +-
.../supervisor/KafkaSupervisorTuningConfig.java | 22 +
.../indexing/kafka/KafkaIndexTaskClientTest.java | 123 ++--
.../kafka/KafkaIndexTaskTuningConfigTest.java | 1 +
.../kafka/supervisor/KafkaSupervisorTest.java | 115 ++--
.../indexing/kinesis/KinesisIndexTaskClient.java | 64 --
.../kinesis/KinesisIndexTaskClientFactory.java | 34 +-
.../kinesis/KinesisIndexingServiceModule.java | 9 -
.../supervisor/KinesisSupervisorTuningConfig.java | 22 +
.../kinesis/KinesisIndexTaskClientTest.java | 121 ++--
.../kinesis/KinesisIndexTaskTuningConfigTest.java | 1 +
.../kinesis/supervisor/KinesisSupervisorTest.java | 117 ++--
indexing-service/pom.xml | 15 +-
.../druid/indexing/common/IndexTaskClient.java | 6 +-
.../SeekableStreamIndexTaskClient.java | 523 ++++------------
.../SeekableStreamIndexTaskClientAsyncImpl.java | 655 ++++++++++++++++++++
.../SeekableStreamIndexTaskClientFactory.java | 131 +++-
... => SeekableStreamIndexTaskClientSyncImpl.java} | 65 +-
.../supervisor/SeekableStreamSupervisor.java | 298 +++++----
.../supervisor/SeekableStreamSupervisorSpec.java | 27 +-
.../SeekableStreamSupervisorTuningConfig.java | 3 +
...SeekableStreamIndexTaskClientAsyncImplTest.java | 667 +++++++++++++++++++++
.../SeekableStreamSupervisorSpecTest.java | 6 +
.../SeekableStreamSupervisorStateTest.java | 60 +-
.../java/org/apache/druid/rpc/RequestBuilder.java | 13 +
.../java/org/apache/druid/rpc/ServiceClient.java | 5 +-
.../org/apache/druid/rpc/ServiceClientImpl.java | 6 +-
.../org/apache/druid/rpc/ServiceRetryPolicy.java | 5 +
.../org/apache/druid/rpc/StandardRetryPolicy.java | 19 +-
.../rpc/indexing/SpecificTaskRetryPolicy.java | 6 +
.../org/apache/druid/rpc/MockServiceClient.java | 128 ++++
.../apache/druid/rpc/ServiceClientImplTest.java | 27 +
41 files changed, 2639 insertions(+), 997 deletions(-)
delete mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskClient.java
delete mode 100644
extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskClient.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskClientAsyncImpl.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/{SeekableStreamIndexTaskClient.java
=> SeekableStreamIndexTaskClientSyncImpl.java} (88%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskClientAsyncImplTest.java
create mode 100644
server/src/test/java/org/apache/druid/rpc/MockServiceClient.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
