This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 04fe56835d5 add druid.expressions.allowVectorizeFallback and default
to false (#17248)
add 0bd13bcd513 Projections prototype (#17214)
No new revisions were added by this update.
Summary of changes:
.../hll/HllSketchAggregatorFactory.java | 20 +
.../hll/HllSketchAggregatorFactoryTest.java | 36 +
.../output/ChannelStageOutputReaderTest.java | 2 +-
.../DatasourceRecordReaderSegmentReaderTest.java | 2 +-
.../indexing/common/task/CompactionTaskTest.java | 1 +
.../data/input/impl/AggregateProjectionSpec.java | 212 ++++
.../util/common/granularity/Granularities.java | 30 +
.../apache/druid/query/DefaultQueryMetrics.java | 6 +
.../java/org/apache/druid/query/QueryContexts.java | 6 +
.../java/org/apache/druid/query/QueryMetrics.java | 5 +
.../druid/query/aggregation/AggregatorFactory.java | 34 +
.../druid/query/aggregation/AggregatorUtil.java | 9 -
.../apache/druid/query/groupby/GroupingEngine.java | 4 +-
.../query/search/DefaultSearchQueryMetrics.java | 6 +
.../query/timeseries/TimeseriesQueryEngine.java | 4 +-
.../apache/druid/query/topn/TopNQueryEngine.java | 4 +-
.../druid/segment/AggregateProjectionMetadata.java | 463 ++++++++
.../druid/segment/AutoTypeColumnIndexer.java | 37 +-
.../apache/druid/segment/AutoTypeColumnMerger.java | 109 +-
.../org/apache/druid/segment/CursorBuildSpec.java | 45 +-
.../org/apache/druid/segment/CursorHolder.java | 12 +
.../segment/DictionaryEncodedColumnMerger.java | 17 +-
.../org/apache/druid/segment/DimensionHandler.java | 12 +-
.../apache/druid/segment/DimensionMergerV9.java | 12 +
.../druid/segment/DoubleDimensionHandler.java | 3 +-
.../druid/segment/DoubleDimensionMergerV9.java | 6 +-
.../druid/segment/FloatDimensionHandler.java | 3 +-
.../druid/segment/FloatDimensionMergerV9.java | 6 +-
.../java/org/apache/druid/segment/IndexIO.java | 136 ++-
.../java/org/apache/druid/segment/IndexMerger.java | 2 +-
.../org/apache/druid/segment/IndexMergerV9.java | 315 ++++-
.../org/apache/druid/segment/IndexableAdapter.java | 2 +
.../apache/druid/segment/LongDimensionHandler.java | 3 +-
.../druid/segment/LongDimensionMergerV9.java | 6 +-
.../java/org/apache/druid/segment/Metadata.java | 70 +-
.../segment/NestedCommonFormatColumnHandler.java | 3 +-
.../druid/segment/NestedDataColumnHandlerV4.java | 3 +-
.../druid/segment/NumericDimensionMergerV9.java | 6 +-
.../org/apache/druid/segment/QueryableIndex.java | 13 +
.../druid/segment/QueryableIndexCursorFactory.java | 46 +
.../druid/segment/QueryableIndexCursorHolder.java | 23 +-
.../segment/QueryableIndexIndexableAdapter.java | 8 +
.../druid/segment/RemapColumnSelectorFactory.java | 73 ++
.../apache/druid/segment/SimpleQueryableIndex.java | 104 +-
.../druid/segment/StringDimensionHandler.java | 2 +
.../druid/segment/StringDimensionMergerV9.java | 47 +-
.../apache/druid/segment/TimeAndDimsPointer.java | 4 +-
.../druid/segment/column/ColumnDescriptor.java | 6 +-
.../apache/druid/segment/column/ColumnHolder.java | 8 +
.../druid/segment/column/SimpleColumnHolder.java | 6 +
.../segment/incremental/IncrementalIndex.java | 35 +-
.../incremental/IncrementalIndexAdapter.java | 26 +-
.../IncrementalIndexColumnSelectorFactory.java | 24 +-
.../incremental/IncrementalIndexCursorFactory.java | 34 +-
.../incremental/IncrementalIndexCursorHolder.java | 51 +-
.../IncrementalIndexPhysicalSegmentInspector.java | 2 +-
.../incremental/IncrementalIndexRowIterator.java | 10 +-
.../incremental/IncrementalIndexRowSelector.java | 33 +
.../incremental/IncrementalIndexSchema.java | 25 +-
.../incremental/OnHeapAggregateProjection.java | 376 ++++++
.../incremental/OnheapIncrementalIndex.java | 139 ++-
.../druid/segment/nested/DictionaryIdLookup.java | 30 +
.../nested/NestedCommonFormatColumnSerializer.java | 4 +-
.../segment/nested/NestedDataColumnSerializer.java | 72 +-
.../segment/nested/NestedDataColumnSupplier.java | 93 +-
.../nested/ScalarDoubleColumnAndIndexSupplier.java | 31 +-
.../nested/ScalarDoubleColumnSerializer.java | 9 +
.../nested/ScalarLongColumnAndIndexSupplier.java | 31 +-
.../segment/nested/ScalarLongColumnSerializer.java | 9 +
.../ScalarNestedCommonFormatColumnSerializer.java | 25 +-
.../nested/ScalarStringColumnAndIndexSupplier.java | 29 +-
.../nested/ScalarStringColumnSerializer.java | 9 +
.../nested/VariantColumnAndIndexSupplier.java | 117 +-
.../segment/nested/VariantColumnSerializer.java | 95 +-
.../druid/segment/projections/Projections.java | 260 ++++
.../segment/projections/QueryableProjection.java | 119 ++
.../druid/segment/serde/ColumnPartSerde.java | 8 +-
.../segment/serde/ComplexColumnPartSerde.java | 2 +-
.../serde/DictionaryEncodedColumnPartSerde.java | 26 +-
.../serde/DoubleNumericColumnPartSerde.java | 2 +-
.../serde/DoubleNumericColumnPartSerdeV2.java | 2 +-
.../segment/serde/FloatNumericColumnPartSerde.java | 32 +-
.../serde/FloatNumericColumnPartSerdeV2.java | 2 +-
.../segment/serde/LongNumericColumnPartSerde.java | 2 +-
.../serde/LongNumericColumnPartSerdeV2.java | 2 +-
.../serde/NestedCommonFormatColumnPartSerde.java | 44 +-
.../druid/segment/serde/NullColumnPartSerde.java | 2 +-
.../StringUtf8DictionaryEncodedColumnSupplier.java | 5 +
.../vector/RemapVectorColumnSelectorFactory.java | 102 ++
.../segment/virtual/ExpressionVirtualColumn.java | 4 +-
.../input/impl/AggregateProjectionSpecTest.java | 105 ++
.../org/apache/druid/frame/file/FrameFileTest.java | 2 +-
.../processor/FrameProcessorExecutorTest.java | 6 +-
.../druid/granularity/QueryGranularityTest.java | 53 +-
.../timeseries/TimeseriesQueryRunnerBonusTest.java | 4 +-
.../segment/AggregateProjectionMetadataTest.java | 149 +++
.../druid/segment/CursorFactoryProjectionTest.java | 1238 ++++++++++++++++++++
.../druid/segment/CursorHolderPreaggTest.java | 11 +
.../IndexIONullColumnsCompatibilityTest.java | 2 +-
.../apache/druid/segment/IndexMergerTestBase.java | 3 +-
.../org/apache/druid/segment/MetadataTest.java | 162 ++-
.../apache/druid/segment/V9IndexLoaderTest.java | 7 +-
.../druid/segment/data/IncrementalIndexTest.java | 18 +-
.../druid/segment/filter/BaseFilterTest.java | 15 +-
.../druid/segment/generator/DataGeneratorTest.java | 2 +-
...java => IncrementalIndexCursorFactoryTest.java} | 210 ++--
.../segment/incremental/IncrementalIndexTest.java | 2 +-
.../nested/NestedDataColumnSupplierTest.java | 9 +-
.../nested/NestedDataColumnSupplierV4Test.java | 2 +-
.../nested/ScalarDoubleColumnSupplierTest.java | 8 +-
.../nested/ScalarLongColumnSupplierTest.java | 8 +-
.../nested/ScalarStringColumnSupplierTest.java | 8 +-
.../segment/nested/VariantColumnSupplierTest.java | 8 +-
.../segment/serde/NullColumnPartSerdeTest.java | 14 +-
.../druid/segment/indexing/CombinedDataSchema.java | 1 +
.../apache/druid/segment/indexing/DataSchema.java | 29 +-
.../realtime/appenderator/BatchAppenderator.java | 2 +-
.../realtime/appenderator/StreamAppenderator.java | 2 +-
.../apache/druid/segment/realtime/sink/Sink.java | 9 +-
.../segment/indexing/TestModifiedDataSchema.java | 1 +
120 files changed, 5378 insertions(+), 627 deletions(-)
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/AggregateProjectionSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/AggregateProjectionMetadata.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/RemapColumnSelectorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/incremental/OnHeapAggregateProjection.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/Projections.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/QueryableProjection.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/vector/RemapVectorColumnSelectorFactory.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/AggregateProjectionSpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/AggregateProjectionMetadataTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/CursorFactoryProjectionTest.java
rename
processing/src/test/java/org/apache/druid/segment/incremental/{IncrementalIndexStorageAdapterTest.java
=> IncrementalIndexCursorFactoryTest.java} (83%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
