You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fj...@apache.org on 2020/03/12 18:07:00 UTC
[druid] branch master updated (3082b92 -> ff59d2e)
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-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org