This is an automated email from the ASF dual-hosted git repository. fjy pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/druid.git.
from 3082b92 Fix NPE when using IndexedTable and all left rows are filtered out (#9490) add ff59d2e Move RowSignature from druid-sql to druid-processing and make use of it. (#9508) No new revisions were added by this update. Summary of changes: .../movingaverage/AveragerFactoryWrapper.java | 7 +- .../sql/TDigestGenerateSketchSqlAggregator.java | 2 +- .../sql/TDigestSketchQuantileSqlAggregator.java | 2 +- .../TimestampGroupByAggregationTest.java | 4 +- .../hll/sql/HllSketchBaseSqlAggregator.java | 4 +- .../sql/HllSketchEstimateOperatorConversion.java | 2 +- ...hEstimateWithErrorBoundsOperatorConversion.java | 2 +- .../sql/HllSketchSetUnionOperatorConversion.java | 2 +- .../sql/HllSketchToStringOperatorConversion.java | 2 +- .../DoublesSketchApproxQuantileSqlAggregator.java | 2 +- ...DoublesSketchListArgBaseOperatorConversion.java | 2 +- .../sql/DoublesSketchObjectSqlAggregator.java | 2 +- ...ublesSketchSingleArgBaseOperatorConversion.java | 2 +- .../DoublesSketchSummaryOperatorConversion.java | 2 +- .../theta/sql/ThetaSketchBaseSqlAggregator.java | 5 +- .../sql/ThetaSketchEstimateOperatorConversion.java | 2 +- ...hEstimateWithErrorBoundsOperatorConversion.java | 2 +- .../sql/ThetaSketchSetBaseOperatorConversion.java | 2 +- .../bloom/sql/BloomFilterSqlAggregator.java | 2 +- .../filter/sql/BloomFilterOperatorConversion.java | 2 +- ...FixedBucketsHistogramQuantileSqlAggregator.java | 2 +- .../histogram/sql/QuantileSqlAggregator.java | 4 +- .../variance/sql/BaseVarianceSqlAggregator.java | 2 +- .../org/apache/druid/query/InlineDataSource.java | 14 +- .../org/apache/druid/query/QueryToolChest.java | 11 +- .../druid/query/aggregation/AggregatorFactory.java | 20 +- .../apache/druid/query/groupby/GroupByQuery.java | 65 ++--- .../druid/query/groupby/GroupByQueryHelper.java | 39 --- .../query/groupby/GroupByQueryQueryToolChest.java | 5 +- .../org/apache/druid/query/groupby/ResultRow.java | 8 +- .../epinephelinae/RowBasedGrouperHelper.java | 7 +- .../query/groupby/having/DimFilterHavingSpec.java | 2 +- .../having/DimensionSelectorHavingSpec.java | 2 +- .../query/groupby/having/EqualToHavingSpec.java | 2 +- .../groupby/having/GreaterThanHavingSpec.java | 2 +- .../query/groupby/having/LessThanHavingSpec.java | 2 +- .../query/groupby/orderby/DefaultLimitSpec.java | 8 +- .../query/groupby/strategy/GroupByStrategyV2.java | 2 +- .../apache/druid/query/lookup/LookupSegment.java | 11 +- .../druid/query/scan/ScanQueryQueryToolChest.java | 39 ++- .../timeseries/TimeseriesQueryQueryToolChest.java | 23 +- .../druid/query/topn/TopNQueryQueryToolChest.java | 24 +- .../segment/RowBasedColumnSelectorFactory.java | 22 +- .../org/apache/druid/segment/RowBasedCursor.java | 5 +- .../org/apache/druid/segment/RowBasedSegment.java | 5 +- .../druid/segment/RowBasedStorageAdapter.java | 9 +- .../apache/druid/segment/column/RowSignature.java | 283 +++++++++++++++++++++ .../org/apache/druid/segment/column/ValueType.java | 3 +- .../segment/incremental/IncrementalIndex.java | 3 +- .../druid/segment/join/table/IndexedTable.java | 19 +- .../table/IndexedTableColumnSelectorFactory.java | 6 +- .../join/table/IndexedTableJoinMatcher.java | 9 +- .../segment/join/table/IndexedTableJoinable.java | 8 +- .../segment/join/table/RowBasedIndexedTable.java | 42 ++- .../druid/segment/transform/Transformer.java | 3 +- .../apache/druid/query/InlineDataSourceTest.java | 13 +- .../groupby/GroupByQueryQueryToolChestTest.java | 26 +- .../query/groupby/GroupByQueryRunnerTest.java | 8 +- .../groupby/GroupByQueryRunnerTestHelper.java | 4 +- .../druid/query/groupby/GroupByQueryTest.java | 3 +- .../query/scan/ScanQueryQueryToolChestTest.java | 23 +- .../TimeseriesQueryQueryToolChestTest.java | 22 +- .../query/topn/TopNQueryQueryToolChestTest.java | 14 +- .../org/apache/druid/segment/IndexBuilder.java | 24 +- .../druid/segment/RowBasedStorageAdapterTest.java | 33 ++- .../druid/segment/filter/BaseFilterTest.java | 9 +- .../join/HashJoinSegmentStorageAdapterTest.java | 4 +- .../apache/druid/segment/join/JoinTestHelper.java | 31 +-- .../druid/segment/join/JoinableClauseTest.java | 2 +- .../join/table/IndexedTableJoinableTest.java | 2 +- .../join/table/RowBasedIndexedTableTest.java | 31 +-- .../virtual/ExpressionVirtualColumnTest.java | 9 +- .../druid/client/CachingClusteredClientTest.java | 2 +- .../segment/join/InlineJoinableFactoryTest.java | 2 +- .../druid/sql/calcite/aggregation/Aggregation.java | 2 +- .../sql/calcite/aggregation/Aggregations.java | 4 +- .../sql/calcite/aggregation/SqlAggregator.java | 2 +- .../builtin/ApproxCountDistinctSqlAggregator.java | 5 +- .../aggregation/builtin/CountSqlAggregator.java | 2 +- .../builtin/EarliestLatestAnySqlAggregator.java | 2 +- .../builtin/MultiColumnSqlAggregator.java | 2 +- .../aggregation/builtin/SimpleSqlAggregator.java | 2 +- .../expression/AliasedOperatorConversion.java | 2 +- .../expression/BinaryOperatorConversion.java | 2 +- .../expression/DirectOperatorConversion.java | 2 +- .../druid/sql/calcite/expression/Expressions.java | 13 +- .../calcite/expression/OperatorConversions.java | 12 +- .../calcite/expression/SqlOperatorConversion.java | 2 +- .../UnaryFunctionOperatorConversion.java | 2 +- .../expression/UnaryPrefixOperatorConversion.java | 2 +- .../expression/UnarySuffixOperatorConversion.java | 2 +- .../ArrayConstructorOperatorConversion.java | 2 +- .../builtin/ArrayContainsOperatorConversion.java | 2 +- .../builtin/ArrayLengthOperatorConversion.java | 2 +- .../builtin/ArrayOffsetOfOperatorConversion.java | 2 +- .../builtin/ArrayOffsetOperatorConversion.java | 2 +- .../builtin/ArrayOrdinalOfOperatorConversion.java | 2 +- .../builtin/ArrayOrdinalOperatorConversion.java | 2 +- .../builtin/ArrayOverlapOperatorConversion.java | 2 +- .../builtin/ArrayToStringOperatorConversion.java | 2 +- .../builtin/BTrimOperatorConversion.java | 2 +- .../expression/builtin/CastOperatorConversion.java | 2 +- .../expression/builtin/CeilOperatorConversion.java | 2 +- .../builtin/ConcatOperatorConversion.java | 2 +- .../builtin/DateTruncOperatorConversion.java | 2 +- .../builtin/ExtractOperatorConversion.java | 2 +- .../builtin/FloorOperatorConversion.java | 2 +- .../expression/builtin/LPadOperatorConversion.java | 2 +- .../builtin/LTrimOperatorConversion.java | 2 +- .../expression/builtin/LeftOperatorConversion.java | 2 +- .../expression/builtin/LikeOperatorConversion.java | 2 +- .../MillisToTimestampOperatorConversion.java | 2 +- .../MultiValueStringAppendOperatorConversion.java | 2 +- .../MultiValueStringConcatOperatorConversion.java | 2 +- .../MultiValueStringPrependOperatorConversion.java | 2 +- .../MultiValueStringSliceOperatorConversion.java | 2 +- .../builtin/ParseLongOperatorConversion.java | 2 +- .../builtin/PositionOperatorConversion.java | 2 +- .../builtin/QueryLookupOperatorConversion.java | 2 +- .../expression/builtin/RPadOperatorConversion.java | 2 +- .../builtin/RTrimOperatorConversion.java | 2 +- .../builtin/RegexpExtractOperatorConversion.java | 2 +- .../builtin/RepeatOperatorConversion.java | 2 +- .../builtin/ReverseOperatorConversion.java | 2 +- .../builtin/RightOperatorConversion.java | 2 +- .../builtin/RoundOperatorConversion.java | 2 +- .../builtin/StringFormatOperatorConversion.java | 2 +- ...StringToMultiValueStringOperatorConversion.java | 2 +- .../builtin/StrposOperatorConversion.java | 2 +- .../builtin/SubstringOperatorConversion.java | 2 +- .../builtin/TextcatOperatorConversion.java | 2 +- .../builtin/TimeArithmeticOperatorConversion.java | 2 +- .../builtin/TimeCeilOperatorConversion.java | 2 +- .../builtin/TimeExtractOperatorConversion.java | 2 +- .../builtin/TimeFloorOperatorConversion.java | 2 +- .../builtin/TimeFormatOperatorConversion.java | 2 +- .../builtin/TimeParseOperatorConversion.java | 2 +- .../builtin/TimeShiftOperatorConversion.java | 2 +- .../TimestampToMillisOperatorConversion.java | 2 +- .../expression/builtin/TrimOperatorConversion.java | 2 +- .../builtin/TruncateOperatorConversion.java | 2 +- .../filtration/ConvertBoundsToSelectors.java | 6 +- .../calcite/filtration/ConvertSelectorsToIns.java | 6 +- .../druid/sql/calcite/filtration/Filtration.java | 2 +- .../sql/calcite/planner/DruidRexExecutor.java | 2 +- .../druid/sql/calcite/rel/DruidJoinQueryRel.java | 15 +- .../druid/sql/calcite/rel/DruidOuterQueryRel.java | 5 +- .../apache/druid/sql/calcite/rel/DruidQuery.java | 31 ++- .../org/apache/druid/sql/calcite/rel/Grouping.java | 4 +- .../druid/sql/calcite/rel/PartialDruidQuery.java | 2 +- .../apache/druid/sql/calcite/rel/Projection.java | 32 ++- .../apache/druid/sql/calcite/rel/QueryMaker.java | 6 +- .../sql/calcite/rel/VirtualColumnRegistry.java | 12 +- .../druid/sql/calcite/rule/GroupByRules.java | 2 +- .../calcite/schema/AvailableSegmentMetadata.java | 2 +- .../druid/sql/calcite/schema/DruidSchema.java | 10 +- .../sql/calcite/schema/InformationSchema.java | 9 +- .../druid/sql/calcite/schema/LookupSchema.java | 2 +- .../druid/sql/calcite/schema/SystemSchema.java | 15 +- .../apache/druid/sql/calcite/table/DruidTable.java | 3 +- .../{RowSignature.java => RowSignatures.java} | 154 ++--------- .../calcite/expression/ExpressionTestHelper.java | 9 +- .../sql/calcite/expression/ExpressionsTest.java | 2 +- .../expression/IPv4AddressMatchExpressionTest.java | 2 +- .../expression/IPv4AddressParseExpressionTest.java | 2 +- .../IPv4AddressStringifyExpressionTest.java | 2 +- .../sql/calcite/filtration/FiltrationTest.java | 2 +- .../druid/sql/calcite/schema/SystemSchemaTest.java | 40 ++- 168 files changed, 883 insertions(+), 681 deletions(-) create mode 100644 processing/src/main/java/org/apache/druid/segment/column/RowSignature.java rename sql/src/main/java/org/apache/druid/sql/calcite/table/{RowSignature.java => RowSignatures.java} (50%) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org For additional commands, e-mail: commits-h...@druid.apache.org