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 0a8262edc8 make sure execution mode is set (#14606)
add 913416c669 add equality, null, and range filter (#14542)
No new revisions were added by this update.
Summary of changes:
...tionaryEncodedStringIndexSupplierBenchmark.java | 10 +-
.../sql/TDigestSketchSqlAggregatorTest.java | 9 +-
.../hll/HllSketchBuildAggregatorFactory.java | 3 +
.../HllSketchBuildVectorProcessorFactory.java | 10 +
.../kll/KllDoublesSketchAggregatorFactory.java | 10 +-
.../kll/KllFloatsSketchAggregatorFactory.java | 10 +-
.../quantiles/DoublesSketchAggregatorFactory.java | 6 +
.../theta/SketchAggregatorFactory.java | 14 +
.../util/ToObjectVectorColumnProcessorFactory.java | 6 +
.../hll/sql/HllSketchSqlAggregatorTest.java | 22 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 39 +-
.../theta/SketchAggregatorFactoryTest.java | 1 +
.../theta/sql/ThetaSketchSqlAggregatorTest.java | 26 +-
.../bloom/sql/BloomFilterSqlAggregatorTest.java | 9 +-
.../expressions/BloomFilterExpressionsTest.java | 2 +-
.../druid/query/filter/BloomDimFilterTest.java | 34 +-
.../query/filter/sql/BloomDimFilterSqlTest.java | 1 +
...dBucketsHistogramQuantileSqlAggregatorTest.java | 23 +-
.../histogram/sql/QuantileSqlAggregatorTest.java | 98 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 23 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 20 +-
.../org/apache/druid/query/sql/SleepSqlTest.java | 4 +-
.../druid/indexing/input/DruidSegmentReader.java | 11 +
.../indexing/input/DruidSegmentReaderTest.java | 113 ++
.../druid/math/expr/BinaryLogicalOperatorExpr.java | 80 +-
.../apache/druid/math/expr/BinaryOperatorExpr.java | 21 +-
.../druid/math/expr/ExpressionTypeConversion.java | 6 +
.../org/apache/druid/math/expr/InputBindings.java | 2 +-
.../vector/CardinalityVectorProcessorFactory.java | 10 +
.../apache/druid/query/filter/BoundDimFilter.java | 489 +++----
.../org/apache/druid/query/filter/DimFilter.java | 5 +-
.../apache/druid/query/filter/DimFilterUtils.java | 4 +
.../druid/query/filter/DruidFloatPredicate.java | 2 +
.../druid/query/filter/DruidPredicateFactory.java | 10 +
.../apache/druid/query/filter/EqualityFilter.java | 581 +++++++++
.../java/org/apache/druid/query/filter/Filter.java | 2 +-
.../org/apache/druid/query/filter/InDimFilter.java | 20 +-
.../org/apache/druid/query/filter/NullFilter.java | 316 +++++
.../org/apache/druid/query/filter/RangeFilter.java | 1062 ++++++++++++++++
...ueMatcher.java => ArrayVectorValueMatcher.java} | 63 +-
.../filter/vector/DoubleVectorValueMatcher.java | 22 +-
.../filter/vector/FloatVectorValueMatcher.java | 21 +-
.../filter/vector/LongVectorValueMatcher.java | 21 +-
.../vector/MultiValueStringVectorValueMatcher.java | 14 +-
.../filter/vector/ObjectVectorValueMatcher.java | 8 +-
.../SingleValueStringVectorValueMatcher.java | 14 +-
.../vector/StringObjectVectorValueMatcher.java | 13 +-
.../VectorValueMatcherColumnProcessorFactory.java | 6 +
.../filter/vector/VectorValueMatcherFactory.java | 3 +
.../GroupByVectorColumnProcessorFactory.java | 13 +
.../druid/query/metadata/SegmentAnalyzer.java | 2 +-
.../semantic/DefaultFramedOnHeapAggregatable.java | 1 -
.../apache/druid/query/search/AutoStrategy.java | 2 +-
.../druid/query/search/UseIndexesStrategy.java | 4 +-
.../druid/segment/AutoTypeColumnIndexer.java | 36 +-
.../druid/segment/ColumnProcessorFactory.java | 11 +
.../org/apache/druid/segment/ColumnProcessors.java | 7 +
.../segment/ColumnSelectorColumnIndexSelector.java | 5 +-
.../org/apache/druid/segment/FilterAnalysis.java | 2 +-
.../org/apache/druid/segment/FilteredOffset.java | 2 +-
.../segment/QueryableIndexIndexableAdapter.java | 2 +-
.../segment/QueryableIndexStorageAdapter.java | 2 +-
.../segment/VectorColumnProcessorFactory.java | 2 +
.../segment/column/CapabilitiesBasedFormat.java | 1 -
.../apache/druid/segment/column/ColumnBuilder.java | 7 -
.../druid/segment/column/ColumnCapabilities.java | 6 -
.../segment/column/ColumnCapabilitiesImpl.java | 15 -
.../apache/druid/segment/column/ColumnConfig.java | 13 +-
.../org/apache/druid/segment/filter/AndFilter.java | 2 +-
.../apache/druid/segment/filter/BoundFilter.java | 79 +-
.../segment/filter/ColumnComparisonFilter.java | 24 +-
.../segment/filter/DimensionPredicateFilter.java | 2 +-
.../druid/segment/filter/ExpressionFilter.java | 33 +-
.../apache/druid/segment/filter/FalseFilter.java | 4 +-
.../org/apache/druid/segment/filter/Filters.java | 41 +-
.../druid/segment/filter/JavaScriptFilter.java | 2 +-
.../apache/druid/segment/filter/LikeFilter.java | 24 +-
.../org/apache/druid/segment/filter/NotFilter.java | 2 +-
.../org/apache/druid/segment/filter/OrFilter.java | 2 +-
.../filter/PredicateValueMatcherFactory.java | 55 +-
.../druid/segment/filter/SelectorFilter.java | 22 +-
.../apache/druid/segment/filter/SpatialFilter.java | 6 +-
...java => StringConstantValueMatcherFactory.java} | 17 +-
.../apache/druid/segment/filter/TrueFilter.java | 4 +-
.../apache/druid/segment/filter/ValueMatchers.java | 37 +-
.../AllFalseBitmapColumnIndex.java | 4 +-
.../AllTrueBitmapColumnIndex.java | 4 +-
.../{column => index}/BitmapColumnIndex.java | 3 +-
...xedStringDictionaryEncodedStringValueIndex.java | 3 +-
.../IndexedStringDruidPredicateIndexes.java} | 10 +-
.../IndexedUtf8LexicographicalRangeIndexes.java} | 11 +-
.../IndexedUtf8ValueIndexes.java} | 44 +-
.../{column => index}/SimpleBitmapColumnIndex.java | 5 +-
.../SimpleImmutableBitmapIndex.java | 2 +-
.../SimpleImmutableBitmapIterableIndex.java | 2 +-
.../DictionaryEncodedStringValueIndex.java | 7 +-
.../semantic}/DictionaryEncodedValueIndex.java | 7 +-
.../semantic/DruidPredicateIndexes.java} | 5 +-
.../semantic/LexicographicalRangeIndexes.java} | 5 +-
.../{column => index/semantic}/NullValueIndex.java | 6 +-
.../semantic/NumericRangeIndexes.java} | 6 +-
.../{column => index/semantic}/SpatialIndex.java | 2 +-
.../semantic/StringValueSetIndexes.java} | 5 +-
.../semantic/Utf8ValueSetIndexes.java} | 5 +-
.../semantic/ValueIndexes.java} | 30 +-
.../segment/join/lookup/LookupJoinMatcher.java | 10 +
.../join/table/IndexedTableJoinMatcher.java | 12 +
.../segment/nested/NestedCommonFormatColumn.java | 3 +-
.../segment/nested/NestedDataComplexTypeSerde.java | 3 +-
.../nested/NestedFieldColumnIndexSupplier.java | 96 +-
.../nested/NestedFieldDictionaryEncodedColumn.java | 30 +-
.../nested/ScalarDoubleColumnAndIndexSupplier.java | 89 +-
.../nested/ScalarLongColumnAndIndexSupplier.java | 89 +-
.../apache/druid/segment/nested/VariantColumn.java | 62 +-
.../nested/VariantColumnAndIndexSupplier.java | 135 +-
.../serde/NestedCommonFormatColumnPartSerde.java | 26 +-
.../druid/segment/serde/NullColumnPartSerde.java | 1 -
.../segment/serde/NullValueIndexSupplier.java | 8 +-
.../serde/StringUtf8ColumnIndexSupplier.java | 50 +-
.../druid/segment/virtual/ExpressionSelectors.java | 4 +-
.../segment/virtual/ListFilteredVirtualColumn.java | 53 +-
.../segment/virtual/NestedFieldVirtualColumn.java | 9 +-
.../RowReadingVectorColumnProcessorFactory.java | 6 +
.../java/org/apache/druid/math/expr/EvalTest.java | 42 +
.../druid/query/expression/ExprMacroTest.java | 2 +-
.../expression/HyperUniqueExpressionsTest.java | 2 +-
.../expression/NestedDataExpressionsTest.java | 2 +-
.../expression/RegexpReplaceExprMacroTest.java | 2 +-
.../apache/druid/query/filter/InDimFilterTest.java | 18 +-
.../druid/query/filter/LikeDimFilterTest.java | 14 +-
.../druid/query/scan/NestedDataScanQueryTest.java | 4 +-
.../druid/segment/AutoTypeColumnIndexerTest.java | 37 +-
.../ColumnSelectorColumnIndexSelectorTest.java | 15 +-
.../org/apache/druid/segment/IndexBuilder.java | 6 +-
.../druid/segment/IndexMergerNullHandlingTest.java | 8 +-
.../apache/druid/segment/IndexMergerTestBase.java | 4 +-
.../druid/segment/NestedDataColumnIndexerTest.java | 36 +-
.../segment/column/ColumnCapabilitiesImplTest.java | 5 +-
.../druid/segment/filter/BaseFilterTest.java | 275 +++-
.../druid/segment/filter/BoundFilterTest.java | 44 +-
.../segment/filter/ColumnComparisonFilterTest.java | 4 +-
.../druid/segment/filter/EqualityFilterTest.java | 678 ++++++++++
.../druid/segment/filter/ExpressionFilterTest.java | 12 +-
.../druid/segment/filter/FilterPartitionTest.java | 20 +-
.../apache/druid/segment/filter/InFilterTest.java | 30 +-
.../druid/segment/filter/JavaScriptFilterTest.java | 21 +-
.../druid/segment/filter/NullFilterTest.java | 269 ++++
.../druid/segment/filter/RangeFilterTest.java | 1338 ++++++++++++++++++++
.../druid/segment/filter/RegexFilterTest.java | 12 +-
.../segment/filter/SearchQueryFilterTest.java | 22 +-
.../druid/segment/filter/SelectorFilterTest.java | 23 +-
.../IncrementalIndexStorageAdapterTest.java | 4 +-
.../apache/druid/segment/join/JoinTestHelper.java | 11 +
.../nested/NestedDataColumnSupplierTest.java | 66 +-
.../nested/NestedDataColumnSupplierV4Test.java | 41 +-
.../nested/NestedFieldColumnIndexSupplierTest.java | 202 +--
.../nested/ScalarDoubleColumnSupplierTest.java | 16 +-
.../nested/ScalarLongColumnSupplierTest.java | 16 +-
.../nested/ScalarStringColumnSupplierTest.java | 14 +-
.../segment/nested/VariantColumnSupplierTest.java | 14 +-
.../DictionaryEncodedStringIndexSupplierTest.java | 6 +-
.../segment/serde/NullColumnPartSerdeTest.java | 1 -
.../ListFilteredVirtualColumnSelectorTest.java | 2 +-
.../test/resources/nested-all-types-test-data.json | 4 +-
.../query/expression/LookupExprMacroTest.java | 2 +-
.../java/org/apache/druid/cli/DumpSegment.java | 2 +-
.../java/org/apache/druid/cli/DumpSegmentTest.java | 2 +-
.../aggregation/builtin/BitwiseSqlAggregator.java | 8 +-
.../aggregation/builtin/StringSqlAggregator.java | 8 +-
.../druid/sql/calcite/expression/Expressions.java | 245 +++-
.../builtin/ArrayContainsOperatorConversion.java | 30 +-
.../builtin/ArrayOverlapOperatorConversion.java | 14 +-
.../expression/builtin/CaseOperatorConversion.java | 20 +-
.../filtration/CombineAndSimplifyBounds.java | 80 +-
.../filtration/ConvertBoundsToSelectors.java | 17 +
.../calcite/filtration/ConvertSelectorsToIns.java | 42 +
.../filtration/MoveTimeFiltersToIntervals.java | 32 +
.../druid/sql/calcite/filtration/RangeRefKey.java | 107 ++
.../druid/sql/calcite/filtration/RangeValue.java | 93 ++
.../druid/sql/calcite/filtration/Ranges.java | 225 ++++
.../apache/druid/sql/calcite/planner/Calcites.java | 9 +-
.../sql/calcite/planner/DruidRexExecutor.java | 5 +-
.../druid/sql/calcite/planner/PlannerContext.java | 22 +
.../druid/sql/calcite/run/NativeQueryMaker.java | 25 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 178 ++-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 87 +-
.../sql/calcite/CalciteCorrelatedQueryTest.java | 32 +-
.../druid/sql/calcite/CalciteExplainQueryTest.java | 108 +-
.../druid/sql/calcite/CalciteInsertDmlTest.java | 4 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 491 +++----
.../calcite/CalciteMultiValueStringQueryTest.java | 38 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 1078 ++++++++++++++--
.../sql/calcite/CalciteParameterQueryTest.java | 21 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 822 +++++++-----
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 2 +-
.../druid/sql/calcite/CalciteSelectQueryTest.java | 91 +-
.../druid/sql/calcite/CalciteSubqueryTest.java | 20 +-
197 files changed, 9688 insertions(+), 2254 deletions(-)
create mode 100644
processing/src/main/java/org/apache/druid/query/filter/EqualityFilter.java
create mode 100644
processing/src/main/java/org/apache/druid/query/filter/NullFilter.java
create mode 100644
processing/src/main/java/org/apache/druid/query/filter/RangeFilter.java
copy
processing/src/main/java/org/apache/druid/query/filter/vector/{StringObjectVectorValueMatcher.java
=> ArrayVectorValueMatcher.java} (61%)
rename
processing/src/main/java/org/apache/druid/segment/filter/{ConstantValueMatcherFactory.java
=> StringConstantValueMatcherFactory.java} (80%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/AllFalseBitmapColumnIndex.java (90%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/AllTrueBitmapColumnIndex.java (90%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/BitmapColumnIndex.java (91%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/IndexedStringDictionaryEncodedStringValueIndex.java (94%)
rename
processing/src/main/java/org/apache/druid/segment/{column/IndexedStringDruidPredicateIndex.java
=> index/IndexedStringDruidPredicateIndexes.java} (89%)
rename
processing/src/main/java/org/apache/druid/segment/{column/IndexedUtf8LexicographicalRangeIndex.java
=> index/IndexedUtf8LexicographicalRangeIndexes.java} (94%)
rename
processing/src/main/java/org/apache/druid/segment/{column/IndexedUtf8ValueSetIndex.java
=> index/IndexedUtf8ValueIndexes.java} (83%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/SimpleBitmapColumnIndex.java (87%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/SimpleImmutableBitmapIndex.java (97%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index}/SimpleImmutableBitmapIterableIndex.java (97%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index/semantic}/DictionaryEncodedStringValueIndex.java (85%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index/semantic}/DictionaryEncodedValueIndex.java (85%)
rename
processing/src/main/java/org/apache/druid/segment/{column/DruidPredicateIndex.java
=> index/semantic/DruidPredicateIndexes.java} (90%)
rename
processing/src/main/java/org/apache/druid/segment/{column/LexicographicalRangeIndex.java
=> index/semantic/LexicographicalRangeIndexes.java} (95%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index/semantic}/NullValueIndex.java (87%)
rename
processing/src/main/java/org/apache/druid/segment/{column/NumericRangeIndex.java
=> index/semantic/NumericRangeIndexes.java} (92%)
rename processing/src/main/java/org/apache/druid/segment/{column =>
index/semantic}/SpatialIndex.java (95%)
copy
processing/src/main/java/org/apache/druid/segment/{column/StringValueSetIndex.java
=> index/semantic/StringValueSetIndexes.java} (91%)
rename
processing/src/main/java/org/apache/druid/segment/{column/Utf8ValueSetIndex.java
=> index/semantic/Utf8ValueSetIndexes.java} (89%)
rename
processing/src/main/java/org/apache/druid/segment/{column/StringValueSetIndex.java
=> index/semantic/ValueIndexes.java} (55%)
create mode 100644
processing/src/test/java/org/apache/druid/segment/filter/EqualityFilterTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/filter/NullFilterTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/filter/RangeFilterTest.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/filtration/RangeRefKey.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/filtration/RangeValue.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/filtration/Ranges.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
