This is an automated email from the ASF dual-hosted git repository.
karan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 3df161f73cb docs: update security doc for hashing (#15970)
add d2c2036ea2b Optimize MSQ realtime queries (#15399)
No new revisions were added by this update.
Summary of changes:
.../druid/msq/exec/DataServerQueryHandler.java | 381 +++++++++++++++++++++
...ory.java => DataServerQueryHandlerFactory.java} | 19 +-
.../druid/msq/exec/DataServerQueryResult.java | 60 ++++
.../druid/msq/exec/LoadedSegmentDataProvider.java | 268 ---------------
.../org/apache/druid/msq/exec/WorkerContext.java | 2 +-
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 2 +-
.../druid/msq/indexing/IndexerFrameContext.java | 12 +-
.../druid/msq/indexing/IndexerWorkerContext.java | 16 +-
.../org/apache/druid/msq/input/ReadableInput.java | 53 ++-
.../input/external/ExternalInputSliceReader.java | 3 +-
.../msq/input/inline/InlineInputSliceReader.java | 3 +-
.../msq/input/lookup/LookupInputSliceReader.java | 3 +-
.../input/table/DataServerRequestDescriptor.java | 65 ++--
.../druid/msq/input/table/DataServerSelector.java | 32 +-
.../msq/input/table/RichSegmentDescriptor.java | 44 +--
.../msq/input/table/SegmentWithDescriptor.java | 29 --
.../druid/msq/input/table/SegmentsInputSlice.java | 25 +-
.../msq/input/table/SegmentsInputSliceReader.java | 44 ++-
.../msq/input/table/TableInputSpecSlicer.java | 145 +++++++-
.../org/apache/druid/msq/kernel/FrameContext.java | 5 +-
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 31 +-
.../querykit/BaseLeafFrameProcessorFactory.java | 97 ++++--
.../msq/querykit/ChainedProcessorManager.java | 70 ++--
.../groupby/GroupByPreShuffleFrameProcessor.java | 46 ++-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 46 ++-
...erTest.java => DataServerQueryHandlerTest.java} | 211 +++++++++---
.../druid/msq/exec/MSQLoadedSegmentTests.java | 98 +++---
...t.java => DataServerRequestDescriptorTest.java} | 53 +--
.../msq/input/table/RichSegmentDescriptorTest.java | 22 +-
.../msq/input/table/SegmentWithDescriptorTest.java | 3 -
.../msq/input/table/SegmentsInputSliceTest.java | 17 +-
.../msq/input/table/TableInputSpecSlicerTest.java | 117 +++----
.../druid/msq/test/CalciteMSQTestsHelper.java | 25 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 16 +-
.../druid/msq/test/MSQTestWorkerContext.java | 8 +-
.../druid/discovery/DataServerResponseHandler.java | 221 ++++++++++--
.../apache/druid/rpc/FixedSetServiceLocator.java | 7 +-
.../druid/discovery/DataServerClientTest.java | 100 +++++-
.../druid/rpc/FixedSetServiceLocatorTest.java | 25 +-
39 files changed, 1600 insertions(+), 824 deletions(-)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/DataServerQueryHandler.java
rename
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/{LoadedSegmentDataProviderFactory.java
=> DataServerQueryHandlerFactory.java} (82%)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/DataServerQueryResult.java
delete mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/LoadedSegmentDataProvider.java
copy
server/src/main/java/org/apache/druid/client/ImmutableSegmentLoadInfo.java =>
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/DataServerRequestDescriptor.java
(51%)
copy
server/src/main/java/org/apache/druid/client/FilteredServerInventoryView.java
=>
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/DataServerSelector.java
(54%)
rename
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/{LoadedSegmentDataProviderTest.java
=> DataServerQueryHandlerTest.java} (50%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/{SegmentsInputSliceTest.java
=> DataServerRequestDescriptorTest.java} (58%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
