This is an automated email from the ASF dual-hosted git repository.
abhishek pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 5b6a2a26147 indexing-service no longer depends on indexing-hadoop
(#18247)
add 01dd8d1e2c2 Dart: Async queries to realtime servers. (#18241)
No new revisions were added by this update.
Summary of changes:
.../druid/msq/dart/guice/DartWorkerModule.java | 20 ++
.../dart/worker/DartDataServerQueryHandler.java | 153 +++++++++
.../worker/DartDataServerQueryHandlerFactory.java | 65 ++++
.../dart/worker/DartWorkerContextFactoryImpl.java | 19 +-
.../druid/msq/exec/DataServerQueryHandler.java | 354 ++-------------------
.../msq/exec/DataServerQueryHandlerFactory.java | 68 +---
.../msq/exec/DataServerQueryHandlerUtils.java | 94 ++++++
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 1 -
.../IndexerDataServerQueryHandler.java} | 172 +++++-----
.../IndexerDataServerQueryHandlerFactory.java} | 47 +--
.../druid/msq/indexing/IndexerFrameContext.java | 4 +-
.../druid/msq/indexing/IndexerWorkerContext.java | 6 +-
.../msq/input/table/RichSegmentDescriptor.java | 8 +
.../groupby/GroupByPreShuffleFrameProcessor.java | 25 +-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 26 +-
.../druid/msq/exec/MSQLoadedSegmentTests.java | 93 +++---
.../IndexerDataServerQueryHandlerTest.java} | 87 ++---
.../frame/processor/FrameProcessorExecutor.java | 30 +-
.../druid/frame/processor/ReturnOrAwait.java | 113 ++++---
.../processor/FrameProcessorExecutorTest.java | 65 ++++
.../druid/frame/processor/ReturnOrAwaitTest.java | 19 +-
.../processor/test/FutureWaitingProcessor.java | 104 ++++++
.../apache/druid/discovery/DataServerClient.java | 132 ++++----
.../java/org/apache/druid/rpc/ServiceLocation.java | 12 +
.../druid/discovery/DataServerClientTest.java | 11 +-
.../testing/embedded/EmbeddedDruidCluster.java | 1 +
26 files changed, 983 insertions(+), 746 deletions(-)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartDataServerQueryHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartDataServerQueryHandlerFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/DataServerQueryHandlerUtils.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{exec/DataServerQueryHandler.java
=> indexing/IndexerDataServerQueryHandler.java} (72%)
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{exec/DataServerQueryHandlerFactory.java
=> indexing/IndexerDataServerQueryHandlerFactory.java} (55%)
rename
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/{exec/DataServerQueryHandlerTest.java
=> indexing/IndexerDataServerQueryHandlerTest.java} (78%)
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/test/FutureWaitingProcessor.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
