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 277b357256 Optimize IntervalIterator (#14530)
add 5fc122a144 Add window-focused tests from Drill (#13773)
No new revisions were added by this update.
Summary of changes:
LICENSE | 3 +
extensions-core/parquet-extensions/pom.xml | 2 +-
.../druid/data/input/parquet/ParquetToJson.java | 69 +
.../parquet/simple/ParquetGroupConverter.java | 24 +-
.../data/input/parquet/ParquetToJsonTest.java | 79 +
.../src/test/resources/smlTbl.parquet | Bin 0 -> 3271 bytes
licenses.yaml | 11 +
.../org/apache/druid/error/DruidException.java | 24 +-
.../read/columnar/ComplexFrameColumnReader.java | 68 +-
.../read/columnar/DoubleFrameColumnReader.java | 72 +-
.../read/columnar/FloatFrameColumnReader.java | 72 +-
.../frame/read/columnar/FrameColumnReader.java | 6 +
.../frame/read/columnar/LongFrameColumnReader.java | 73 +-
.../read/columnar/StringFrameColumnReader.java | 51 +-
.../jackson/DruidDefaultSerializersModule.java | 18 +
.../query/operator/LimitTimeIntervalOperator.java | 78 +
.../query/operator/NaivePartitioningOperator.java | 99 +-
.../druid/query/operator/OperatorSequence.java | 1 +
.../apache/druid/query/operator/ScanOperator.java | 118 +
.../druid/query/operator/ScanOperatorFactory.java | 136 +
.../operator/SegmentToRowsAndColumnsOperator.java | 7 +-
.../druid/query/operator/SequenceOperator.java | 136 +-
.../druid/query/operator/WindowOperatorQuery.java | 110 +-
.../WindowOperatorQueryQueryRunnerFactory.java | 38 +-
.../operator/join/SortedInnerJoinOperator.java | 63 +-
.../query/rowsandcols/ArrayListRowsAndColumns.java | 2 +-
.../rowsandcols/LazilyDecoratedRowsAndColumns.java | 361 +
.../rowsandcols/MapOfColumnsRowsAndColumns.java | 35 +
.../rowsandcols/column/ObjectArrayColumn.java | 1 +
.../column/accessor/DoubleColumnAccessorBase.java | 74 +
.../column/accessor/FloatColumnAccessorBase.java | 74 +
.../column/accessor/LongColumnAccessorBase.java | 74 +
.../{ => accessor}/ObjectColumnAccessorBase.java | 4 +-
.../concrete/ColumnHolderRACColumn.java | 188 +
.../rowsandcols/concrete/FrameRowsAndColumns.java | 86 +
.../concrete/QueryableIndexRowsAndColumns.java | 106 +
.../DefaultColumnSelectorFactoryMaker.java | 352 +-
.../semantic/DefaultRowsAndColumnsDecorator.java | 149 +
.../semantic/RowsAndColumnsDecorator.java | 71 +
.../rowsandcols/semantic/WireTransferable.java} | 26 +-
.../apache/druid/segment/DimensionSelector.java | 7 +-
.../druid/segment/QueryableIndexSegment.java | 18 +-
.../druid/query/operator/OperatorSequenceTest.java | 8 +-
.../druid/query/operator/OperatorTestHelper.java | 64 +-
.../query/operator/ScanOperatorFactoryTest.java | 296 +
.../SegmentToRowsAndColumnsOperatorTest.java | 2 +-
.../druid/query/operator/SequenceOperatorTest.java | 7 +-
.../query/operator/WindowOperatorQueryTest.java | 18 +-
.../operator/WindowProcessorOperatorTest.java | 2 +-
.../query/rowsandcols/TestRowsAndColumns.java | 73 +
.../semantic/RowsAndColumnsDecoratorTest.java | 243 +
.../semantic/TestRowsAndColumnsDecorator.java | 144 +
.../apache/druid/sql/calcite/rel/DruidQuery.java | 19 +-
.../apache/druid/sql/calcite/rel/Windowing.java | 77 +-
.../druid/sql/calcite/CalciteWindowQueryTest.java | 2 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 243 +
.../tests/window/wikipediaScanWindow.sqlTest | 255 +-
.../resources/drill/window/datasources/allData.csv | 11196 +++++++++++++++++++
.../drill/window/datasources/allTypsUniq.parquet | Bin 0 -> 2364 bytes
.../window/datasources/allTypsUniq.parquet.json | 22 +
.../window/datasources/fewRowsAllData.parquet | Bin 0 -> 3990 bytes
.../window/datasources/fewRowsAllData.parquet.json | 78 +
.../drill/window/datasources/forViewCrn.parquet | Bin 0 -> 2383 bytes
.../window/datasources/forViewCrn.parquet.json | 30 +
.../drill/window/datasources/smlTbl.parquet | Bin 0 -> 3271 bytes
.../drill/window/datasources/smlTbl.parquet.json | 56 +
.../drill/window/datasources/t_alltype.csv | 145 +
.../drill/window/datasources/t_alltype.parquet | Bin 0 -> 12340 bytes
.../window/datasources/t_alltype.parquet.json | 145 +
.../drill/window/datasources/tblWnulls.parquet | Bin 0 -> 395 bytes
.../window/datasources/tblWnulls.parquet.json | 30 +
.../drill/window/queries/aggregates/aggOWnFn_1.e | 22 +
.../drill/window/queries/aggregates/aggOWnFn_1.q | 12 +
.../drill/window/queries/aggregates/aggOWnFn_2.e | 22 +
.../drill/window/queries/aggregates/aggOWnFn_2.q | 1 +
75 files changed, 15825 insertions(+), 373 deletions(-)
create mode 100644
extensions-core/parquet-extensions/src/main/java/org/apache/druid/data/input/parquet/ParquetToJson.java
create mode 100644
extensions-core/parquet-extensions/src/test/java/org/apache/druid/data/input/parquet/ParquetToJsonTest.java
create mode 100644
extensions-core/parquet-extensions/src/test/resources/smlTbl.parquet
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/LimitTimeIntervalOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/ScanOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/ScanOperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/LazilyDecoratedRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/accessor/DoubleColumnAccessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/accessor/FloatColumnAccessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/accessor/LongColumnAccessorBase.java
rename processing/src/main/java/org/apache/druid/query/rowsandcols/column/{ =>
accessor}/ObjectColumnAccessorBase.java (95%)
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/concrete/ColumnHolderRACColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/concrete/FrameRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/concrete/QueryableIndexRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultRowsAndColumnsDecorator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/RowsAndColumnsDecorator.java
copy
processing/src/main/java/org/apache/druid/{frame/read/columnar/FrameColumnReader.java
=> query/rowsandcols/semantic/WireTransferable.java} (61%)
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/ScanOperatorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/TestRowsAndColumns.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/RowsAndColumnsDecoratorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/TestRowsAndColumnsDecorator.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/DrillWindowQueryTest.java
create mode 100755 sql/src/test/resources/drill/window/datasources/allData.csv
create mode 100644
sql/src/test/resources/drill/window/datasources/allTypsUniq.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/allTypsUniq.parquet.json
create mode 100644
sql/src/test/resources/drill/window/datasources/fewRowsAllData.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/fewRowsAllData.parquet.json
create mode 100644
sql/src/test/resources/drill/window/datasources/forViewCrn.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/forViewCrn.parquet.json
create mode 100644
sql/src/test/resources/drill/window/datasources/smlTbl.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/smlTbl.parquet.json
create mode 100644
sql/src/test/resources/drill/window/datasources/t_alltype.csv
create mode 100644
sql/src/test/resources/drill/window/datasources/t_alltype.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/t_alltype.parquet.json
create mode 100644
sql/src/test/resources/drill/window/datasources/tblWnulls.parquet
create mode 100644
sql/src/test/resources/drill/window/datasources/tblWnulls.parquet.json
create mode 100644
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_2.q
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
