This is an automated email from the ASF dual-hosted git repository.
cheddar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from cf472162a6 fix issue with jetty graceful shutdown of data servers when
druid.serverview.type=http (#13499)
add 83261f9641 Starting on Window Functions (#13458)
No new revisions were added by this update.
Summary of changes:
.../druid/segment/column/TypeStrategies.java | 26 +-
.../apache/druid/segment/column/TypeStrategy.java | 9 +-
.../druid/segment/column/TypeStrategiesTest.java | 10 +-
.../read/columnar/ComplexFrameColumnReader.java | 14 +-
.../read/columnar/DoubleFrameColumnReader.java | 12 +-
.../read/columnar/FloatFrameColumnReader.java | 12 +-
.../frame/read/columnar/LongFrameColumnReader.java | 12 +-
.../write/columnar/ComplexFrameColumnWriter.java | 90 +-
...ameColumnWriter.java => ComplexFrameMaker.java} | 48 +-
.../write/columnar/DoubleFrameColumnWriter.java | 55 +-
...rameColumnWriter.java => DoubleFrameMaker.java} | 49 +-
.../write/columnar/FloatFrameColumnWriter.java | 55 +-
...FrameColumnWriter.java => FloatFrameMaker.java} | 49 +-
.../write/columnar/LongFrameColumnWriter.java | 55 +-
...gFrameColumnWriter.java => LongFrameMaker.java} | 49 +-
.../org/apache/druid/query/InlineDataSource.java | 8 +-
.../main/java/org/apache/druid/query/Query.java | 20 +-
.../query/operator/LimitedRowsAndColumns.java | 115 +++
.../query/operator/NaivePartitioningOperator.java | 100 ++
.../operator/NaivePartitioningOperatorFactory.java | 68 ++
.../org/apache/druid/query/operator/Operator.java | 93 ++
.../druid/query/operator/OperatorFactory.java | 59 ++
.../druid/query/operator/OperatorSequence.java | 125 +++
.../operator/SegmentToRowsAndColumnsOperator.java | 68 ++
.../druid/query/operator/SequenceOperator.java | 87 ++
.../query/operator/WindowOperatorFactory.java | 68 ++
.../druid/query/operator/WindowOperatorQuery.java | 167 ++++
.../WindowOperatorQueryQueryRunnerFactory.java | 55 ++
.../WindowOperatorQueryQueryToolChest.java | 191 ++++
.../query/operator/WindowProcessorOperator.java | 67 ++
.../query/operator/window/ComposingProcessor.java | 78 ++
.../druid/query/operator/window/Processor.java | 83 ++
.../operator/window/WindowAggregateProcessor.java | 131 +++
.../window/ranking/WindowCumeDistProcessor.java | 60 ++
.../window/ranking/WindowDenseRankProcessor.java | 59 ++
.../window/ranking/WindowPercentileProcessor.java | 106 ++
.../window/ranking/WindowRankProcessor.java | 108 ++
.../window/ranking/WindowRankingProcessorBase.java | 103 ++
.../window/ranking/WindowRowNumberProcessor.java | 131 +++
.../window/value/ShiftedColumnAccessorBase.java | 130 +++
.../window/value/WindowFirstProcessor.java | 50 +
.../operator/window/value/WindowLastProcessor.java | 53 +
.../window/value/WindowOffsetProcessor.java | 89 ++
.../window/value/WindowValueProcessorBase.java | 103 ++
.../rowsandcols/AppendableRowsAndColumns.java | 38 +
.../query/rowsandcols/ArrayListRowsAndColumns.java | 125 +++
.../query/rowsandcols/DefaultGroupPartitioner.java | 75 ++
.../rowsandcols/DefaultOnHeapAggregatable.java | 271 ++++++
.../rowsandcols/DefaultSortedGroupPartitioner.java | 93 ++
.../druid/query/rowsandcols/GroupPartitioner.java | 43 +
.../query/rowsandcols/OnHeapAggregatable.java | 47 +
.../rowsandcols/OnHeapCumulativeAggregatable.java | 48 +
.../druid/query/rowsandcols/RowsAndColumns.java | 113 +++
.../query/rowsandcols/SortedGroupPartitioner.java | 54 +
.../druid/query/rowsandcols/column/Column.java | 63 ++
.../query/rowsandcols/column/ColumnAccessor.java | 104 ++
.../column/ColumnAccessorBasedColumn.java | 44 +
.../rowsandcols/column/ConstantObjectColumn.java | 103 ++
.../rowsandcols/column/DoubleArrayColumn.java | 101 ++
.../query/rowsandcols/column/IntArrayColumn.java | 101 ++
.../rowsandcols/column/NullColumnAccessor.java | 96 ++
.../rowsandcols/column/ObjectArrayColumn.java | 81 ++
.../column/ObjectColumnAccessorBase.java | 121 +++
.../rowsandcols/frame/AppendableMapOfColumns.java | 93 ++
.../frame/MapOfColumnsRowsAndColumns.java | 109 +++
.../org/apache/druid/segment/ArrayListSegment.java | 126 +++
.../segment/BaseSingleValueDimensionSelector.java | 1 -
.../java/org/apache/druid/segment/Segment.java | 5 +-
.../column/ObjectStrategyComplexTypeStrategy.java | 4 +-
.../segment/nested/NestedDataColumnSerializer.java | 4 +-
.../druid/query/operator/InlineScanOperator.java | 73 ++
.../operator/NaivePartitioningOperatorTest.java | 105 ++
.../druid/query/operator/OperatorSequenceTest.java | 56 ++
.../druid/query/operator/SequenceOperatorTest.java | 56 ++
.../query/operator/WindowOperatorQueryTest.java | 124 +++
.../operator/WindowProcessorOperatorTest.java | 66 ++
.../operator/window/ComposingProcessorTest.java | 74 ++
.../operator/window/RowsAndColumnsHelper.java | 269 +++++
.../window/WindowAggregateProcessorTest.java | 115 +++
.../ranking/WindowCumeDistProcessorTest.java | 53 +
.../ranking/WindowDenseRankProcessorTest.java | 54 +
.../ranking/WindowPercentileProcessorTest.java | 84 ++
.../window/ranking/WindowRankProcessorTest.java | 84 ++
.../ranking/WindowRowNumberProcessorTest.java | 61 ++
.../window/value/WindowFirstProcessorTest.java | 80 ++
.../window/value/WindowLagProcessorTest.java | 77 ++
.../window/value/WindowLastProcessorTest.java | 78 ++
.../window/value/WindowLeadProcessorTest.java | 76 ++
.../rowsandcols/ArrayListRowsAndColumnsTest.java | 66 ++
.../MapOfColumnsRowsAndColumnsTest.java | 78 ++
.../query/rowsandcols/RowsAndColumnsTestBase.java | 188 ++++
.../rowsandcols/column/NullColumnAccessorTest.java | 46 +
.../nested/NestedDataColumnSupplierTest.java | 2 +-
.../druid/guice/QueryRunnerFactoryModule.java | 13 +-
.../apache/druid/guice/QueryToolChestModule.java | 13 +-
.../druid/segment/InlineSegmentWrangler.java | 16 +-
.../druid/server/ClientQuerySegmentWalker.java | 39 +-
.../druid/server/LocalQuerySegmentWalker.java | 10 +-
.../druid/server/coordination/ServerManager.java | 6 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 1 -
.../org/apache/druid/server/QueryStackTests.java | 6 +-
.../server/TestClusterQuerySegmentWalker.java | 4 -
sql/pom.xml | 19 +-
.../druid/sql/calcite/expression/Expressions.java | 7 +-
.../sql/calcite/expression/WindowSqlAggregate.java | 70 ++
.../sql/calcite/planner/CalciteRulesManager.java | 11 +-
.../sql/calcite/planner/DruidOperatorTable.java | 11 +
.../apache/druid/sql/calcite/rel/DruidQuery.java | 89 +-
.../druid/sql/calcite/rel/PartialDruidQuery.java | 80 +-
.../apache/druid/sql/calcite/rel/Windowing.java | 298 ++++++
.../apache/druid/sql/calcite/rule/DruidRules.java | 121 ++-
.../druid/sql/calcite/rule/GroupByRules.java | 3 +-
.../druid/sql/calcite/run/NativeQueryMaker.java | 3 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 12 +
.../druid/sql/calcite/BaseCalciteQueryTest.java | 1 -
.../apache/druid/sql/calcite/CalciteQueryTest.java | 2 +
.../druid/sql/calcite/CalciteWindowQueryTest.java | 229 +++++
.../apache/druid/sql/calcite/QueryTestBuilder.java | 27 +-
.../apache/druid/sql/calcite/QueryTestRunner.java | 63 +-
.../druid/sql/calcite/QueryVerification.java | 55 ++
.../util/SpecificSegmentsQuerySegmentWalker.java | 1 -
.../druid/sql/calcite/util/SqlTestFramework.java | 13 +-
.../druid/sql/calcite/util/TestDataBuilder.java | 575 ++++++-----
.../tests/wikiticker-2015-09-12-sampled.jgz | Bin
.../calcite/tests/window/simpleSum.sqlTest | 25 +
.../window/wikipediaCumulativeOrdered.sqlTest | 1028 ++++++++++++++++++++
.../tests/window/wikipediaSimplePartition.sqlTest | 1019 +++++++++++++++++++
127 files changed, 10250 insertions(+), 768 deletions(-)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{ComplexFrameColumnWriter.java
=> ComplexFrameMaker.java} (73%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{DoubleFrameColumnWriter.java
=> DoubleFrameMaker.java} (75%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{FloatFrameColumnWriter.java
=> FloatFrameMaker.java} (75%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{LongFrameColumnWriter.java
=> LongFrameMaker.java} (75%)
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/LimitedRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/NaivePartitioningOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/NaivePartitioningOperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/Operator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/OperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/OperatorSequence.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/SegmentToRowsAndColumnsOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/SequenceOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQuery.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQueryQueryRunnerFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQueryQueryToolChest.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowProcessorOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ComposingProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/WindowAggregateProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowCumeDistProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowDenseRankProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowPercentileProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRankProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRankingProcessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRowNumberProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/ShiftedColumnAccessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowFirstProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowLastProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowOffsetProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowValueProcessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/AppendableRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/ArrayListRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/DefaultGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/DefaultOnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/DefaultSortedGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/GroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/OnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/OnHeapCumulativeAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/RowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/SortedGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/Column.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ColumnAccessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ColumnAccessorBasedColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ConstantObjectColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/DoubleArrayColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/IntArrayColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/NullColumnAccessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ObjectArrayColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ObjectColumnAccessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/frame/AppendableMapOfColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/frame/MapOfColumnsRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ArrayListSegment.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/InlineScanOperator.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/NaivePartitioningOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/OperatorSequenceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/SequenceOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/WindowOperatorQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/WindowProcessorOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ComposingProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/RowsAndColumnsHelper.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/WindowAggregateProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowCumeDistProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowDenseRankProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowPercentileProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowRankProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowRowNumberProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowFirstProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLagProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLastProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLeadProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/ArrayListRowsAndColumnsTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/MapOfColumnsRowsAndColumnsTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/RowsAndColumnsTestBase.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/column/NullColumnAccessorTest.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/expression/WindowSqlAggregate.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rel/Windowing.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteWindowQueryTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/QueryVerification.java
copy examples/quickstart/tutorial/wikiticker-2015-09-12-sampled.json.gz =>
sql/src/test/resources/calcite/tests/wikiticker-2015-09-12-sampled.jgz (100%)
create mode 100644
sql/src/test/resources/calcite/tests/window/simpleSum.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/wikipediaCumulativeOrdered.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/wikipediaSimplePartition.sqlTest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
