This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from bdc5477094 Adding missed s3 retry handling in storage connector.
(#14086)
add 0884a22c41 MSQ: Support for querying lookup and inline data directly.
(#14048)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/msq/exec/ControllerImpl.java | 6 ++
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 6 ++
.../druid/msq/exec/WorkerMemoryParameters.java | 5 +-
.../apache/druid/msq/guice/MSQIndexingModule.java | 8 ++
.../druid/msq/indexing/IndexerFrameContext.java | 6 +-
.../apache/druid/msq/input/InputSpecSlicer.java | 5 +
.../inline/InlineInputSlice.java} | 43 ++++----
.../msq/input/inline/InlineInputSliceReader.java | 82 +++++++++++++++
.../inline/InlineInputSpec.java} | 37 +++----
.../msq/input/inline/InlineInputSpecSlicer.java} | 15 ++-
.../lookup/LookupInputSlice.java} | 35 ++++---
.../msq/input/lookup/LookupInputSliceReader.java | 111 +++++++++++++++++++++
.../lookup/LookupInputSpec.java} | 29 +++---
.../msq/input/lookup/LookupInputSpecSlicer.java} | 15 ++-
.../org/apache/druid/msq/kernel/FrameContext.java | 4 +-
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 5 -
.../querykit/BaseLeafFrameProcessorFactory.java | 31 +++---
.../druid/msq/querykit/BroadcastJoinHelper.java | 5 -
.../apache/druid/msq/querykit/DataSourcePlan.java | 60 +++++------
.../groupby/GroupByPreShuffleFrameProcessor.java | 3 -
.../GroupByPreShuffleFrameProcessorFactory.java | 2 -
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 3 -
.../scan/ScanQueryFrameProcessorFactory.java | 2 -
.../org/apache/druid/msq/exec/MSQSelectTest.java | 86 ++++++++++++++++
.../InlineInputSliceTest.java} | 26 ++---
.../InlineInputSpecTest.java} | 24 ++---
.../LookupInputSliceTest.java} | 11 +-
.../LookupInputSpecTest.java} | 8 +-
.../msq/querykit/BroadcastJoinHelperTest.java | 3 -
.../querykit/scan/ScanQueryFrameProcessorTest.java | 3 -
.../druid/msq/test/CalciteMSQTestsHelper.java | 7 --
.../org/apache/druid/msq/test/MSQTestBase.java | 29 ++----
.../java/org/apache/druid/query/DataSource.java | 6 +-
.../org/apache/druid/query/JoinDataSource.java | 34 +++++--
.../main/java/org/apache/druid/cli/CliIndexer.java | 2 +
.../main/java/org/apache/druid/cli/CliPeon.java | 2 +
.../calcite/util/CalciteTestInjectorBuilder.java | 4 +-
.../druid/sql/calcite/util/CalciteTests.java | 3 -
.../{BasicTestModule.java => LookylooModule.java} | 8 +-
.../util/SpecificSegmentsQuerySegmentWalker.java | 19 ++--
.../druid/sql/calcite/util/SqlTestFramework.java | 4 +-
.../druid/sql/calcite/util/TestDataBuilder.java | 3 +-
42 files changed, 546 insertions(+), 254 deletions(-)
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{indexing/error/InsertCannotBeEmptyFault.java
=> input/inline/InlineInputSlice.java} (66%)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/inline/InlineInputSliceReader.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{indexing/error/InsertCannotBeEmptyFault.java
=> input/inline/InlineInputSpec.java} (68%)
copy
extensions-core/multi-stage-query/src/{test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpecSlicer.java
=> main/java/org/apache/druid/msq/input/inline/InlineInputSpecSlicer.java}
(80%)
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{indexing/MSQTaskList.java
=> input/lookup/LookupInputSlice.java} (64%)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/lookup/LookupInputSliceReader.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/{indexing/MSQTaskList.java
=> input/lookup/LookupInputSpec.java} (65%)
copy
extensions-core/multi-stage-query/src/{test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpecSlicer.java
=> main/java/org/apache/druid/msq/input/lookup/LookupInputSpecSlicer.java}
(80%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/{external/ExternalInputSliceTest.java
=> inline/InlineInputSliceTest.java} (71%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/{external/ExternalInputSpecTest.java
=> inline/InlineInputSpecTest.java} (73%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/{stage/StageInputSliceTest.java
=> lookup/LookupInputSliceTest.java} (84%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/{stage/StageInputSpecTest.java
=> lookup/LookupInputSpecTest.java} (87%)
rename
sql/src/test/java/org/apache/druid/sql/calcite/util/{BasicTestModule.java =>
LookylooModule.java} (90%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
