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 90175b8927e [Prometheus Emitter] Add to code coverage and remove code
smell (#17362)
add 450fb0147b3 Add GlueingPartitioningOperator + Corresponding changes in
window function layer to consume it for MSQ (#17038)
No new revisions were added by this update.
Summary of changes:
.../WindowOperatorQueryFrameProcessor.java | 353 ++++++---------------
.../WindowOperatorQueryFrameProcessorFactory.java | 37 +--
.../druid/msq/querykit/WindowOperatorQueryKit.java | 246 +++++++-------
.../druid/msq/util/MultiStageQueryContext.java | 8 +
.../org/apache/druid/msq/exec/MSQWindowTest.java | 100 ++++--
...ndowOperatorQueryFrameProcessorFactoryTest.java | 2 +-
.../WindowOperatorQueryFrameProcessorTest.java | 57 +---
.../operator/AbstractPartitioningOperator.java | 226 +++++++++++++
...va => AbstractPartitioningOperatorFactory.java} | 37 +--
.../druid/query/operator/AbstractSortOperator.java | 29 +-
...ctory.java => AbstractSortOperatorFactory.java} | 19 +-
.../operator/GlueingPartitioningOperator.java | 277 ++++++++++++++++
...ava => GlueingPartitioningOperatorFactory.java} | 47 +--
.../query/operator/NaivePartitioningOperator.java | 140 ++------
.../operator/NaivePartitioningOperatorFactory.java | 50 +--
.../druid/query/operator/NaiveSortOperator.java | 8 +-
.../query/operator/NaiveSortOperatorFactory.java | 47 +--
.../org/apache/druid/query/operator/Operator.java | 4 +-
.../druid/query/operator/OperatorFactory.java | 2 +
...ortOperator.java => PartitionSortOperator.java} | 27 +-
.../operator/PartitionSortOperatorFactory.java | 27 +-
.../rowsandcols/LazilyDecoratedRowsAndColumns.java | 10 +-
.../rowsandcols/RearrangedRowsAndColumns.java | 13 +-
.../semantic/DefaultRowsAndColumnsDecorator.java | 3 +-
.../GlueingPartitioningOperatorFactoryTest.java | 13 +-
.../operator/GlueingPartitioningOperatorTest.java | 233 ++++++++++++++
.../operator/NaivePartitioningOperatorTest.java | 73 ++---
.../operator/PartitionSortOperatorFactoryTest.java | 9 +-
.../query/operator/PartitionSortOperatorTest.java | 58 ++++
.../operator/window/RowsAndColumnsHelper.java | 15 +
.../ColumnBasedFrameRowsAndColumnsTest.java | 1 +
.../semantic/EvaluateRowsAndColumnsTest.java | 1 +
32 files changed, 1294 insertions(+), 878 deletions(-)
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/AbstractPartitioningOperator.java
copy
processing/src/main/java/org/apache/druid/query/operator/{NaivePartitioningOperatorFactory.java
=> AbstractPartitioningOperatorFactory.java} (69%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorFactoryTest.java
=>
processing/src/main/java/org/apache/druid/query/operator/AbstractSortOperator.java
(60%)
copy
processing/src/main/java/org/apache/druid/query/operator/{NaiveSortOperatorFactory.java
=> AbstractSortOperatorFactory.java} (76%)
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/GlueingPartitioningOperator.java
copy
processing/src/main/java/org/apache/druid/query/operator/{NaivePartitioningOperatorFactory.java
=> GlueingPartitioningOperatorFactory.java} (57%)
copy
processing/src/main/java/org/apache/druid/query/operator/{NaiveSortOperator.java
=> PartitionSortOperator.java} (64%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorFactoryTest.java
=>
processing/src/main/java/org/apache/druid/query/operator/PartitionSortOperatorFactory.java
(61%)
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorFactoryTest.java
=>
processing/src/test/java/org/apache/druid/query/operator/GlueingPartitioningOperatorFactoryTest.java
(68%)
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/GlueingPartitioningOperatorTest.java
copy
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorFactoryTest.java
=>
processing/src/test/java/org/apache/druid/query/operator/PartitionSortOperatorFactoryTest.java
(73%)
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/PartitionSortOperatorTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
