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 7e8f3e69ef7 Avoid intermediate offsets in bucketStart calculation
logic to handle DST transition (#15038)
add 2ed4fd1ae31 Compute broadcast-join segmentMapFn only once per worker.
(#15007)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/msq/exec/ControllerImpl.java | 2 +-
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 50 ++-
.../druid/msq/exec/WorkerMemoryParameters.java | 11 +-
.../SegmentGeneratorFrameProcessorFactory.java | 42 +-
.../druid/msq/kernel/FrameProcessorFactory.java | 27 +-
.../druid/msq/kernel/ProcessorsAndChannels.java | 18 +-
.../msq/querykit/BaseFrameProcessorFactory.java | 22 +-
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 148 ++-----
.../querykit/BaseLeafFrameProcessorFactory.java | 229 +++++------
.../querykit/BaseLeafFrameProcessorManager.java | 206 ++++++++++
...ava => BroadcastJoinSegmentMapFnProcessor.java} | 179 +++++---
.../msq/querykit/ChainedProcessorManager.java | 114 ++++++
.../druid/msq/querykit/InputNumberDataSource.java | 15 +-
...essor.java => SimpleSegmentMapFnProcessor.java} | 56 ++-
.../querykit/common/OffsetLimitFrameProcessor.java | 9 +-
.../common/OffsetLimitFrameProcessorFactory.java | 15 +-
.../common/SortMergeJoinFrameProcessor.java | 9 +-
.../common/SortMergeJoinFrameProcessorFactory.java | 10 +-
.../groupby/GroupByPostShuffleFrameProcessor.java | 7 +-
.../GroupByPostShuffleFrameProcessorFactory.java | 7 +-
.../groupby/GroupByPreShuffleFrameProcessor.java | 27 +-
.../GroupByPreShuffleFrameProcessorFactory.java | 16 +-
.../results/QueryResultFrameProcessorFactory.java | 10 +-
.../results/QueryResultsFrameProcessor.java | 9 +-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 35 +-
.../scan/ScanQueryFrameProcessorFactory.java | 21 +-
...=> BroadcastJoinSegmentMapFnProcessorTest.java} | 30 +-
.../common/SortMergeJoinFrameProcessorTest.java | 5 +-
.../results/QueryResultsFrameProcessorTest.java | 5 +-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 16 +-
.../frame/processor/FrameProcessorExecutor.java | 19 +-
.../druid/frame/processor/FrameProcessors.java | 4 +-
.../druid/frame/processor/RunAllFullyWidget.java | 191 +++++----
.../manager/AccumulatingProcessorManager.java | 83 ++++
.../processor/manager/ProcessorAndCallback.java | 37 +-
.../frame/processor/manager/ProcessorManager.java | 98 +++++
.../frame/processor/manager/ProcessorManagers.java | 70 ++++
.../manager/SequenceProcessorManager.java | 110 +++++
.../org/apache/druid/java/util/common/Unit.java | 37 +-
.../org/apache/druid/query/JoinDataSource.java | 157 ++++---
.../java/org/apache/druid/common/UnitTest.java | 39 ++
.../frame/processor/RunAllFullyWidgetTest.java | 450 ++++++++++++++++-----
.../manager/SequenceProcessorManagerTest.java | 169 ++++++++
43 files changed, 1964 insertions(+), 850 deletions(-)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessorManager.java
rename
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/{BroadcastJoinHelper.java
=> BroadcastJoinSegmentMapFnProcessor.java} (62%)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/ChainedProcessorManager.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/{results/QueryResultsFrameProcessor.java
=> SimpleSegmentMapFnProcessor.java} (51%)
rename
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/{BroadcastJoinHelperTest.java
=> BroadcastJoinSegmentMapFnProcessorTest.java} (90%)
create mode 100644
processing/src/main/java/org/apache/druid/frame/processor/manager/AccumulatingProcessorManager.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ProcessorsAndChannels.java
=>
processing/src/main/java/org/apache/druid/frame/processor/manager/ProcessorAndCallback.java
(53%)
create mode 100644
processing/src/main/java/org/apache/druid/frame/processor/manager/ProcessorManager.java
create mode 100644
processing/src/main/java/org/apache/druid/frame/processor/manager/ProcessorManagers.java
create mode 100644
processing/src/main/java/org/apache/druid/frame/processor/manager/SequenceProcessorManager.java
copy
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ProcessorsAndChannels.java
=> processing/src/main/java/org/apache/druid/java/util/common/Unit.java (50%)
create mode 100644
processing/src/test/java/org/apache/druid/common/UnitTest.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/manager/SequenceProcessorManagerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
