You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by cw...@apache.org on 2022/02/09 22:56:29 UTC
[druid] branch master updated (33bc922 -> 3ee66bb)
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 33bc922 Move task creation under stateChangeLock in SeekableStreamSupervisor (#12178)
add 3ee66bb allow optimizing sql expressions and virtual columns (#12241)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/druid/math/expr/Expr.java | 5 +
.../org/apache/druid/math/expr/IdentifierExpr.java | 6 +
.../org/apache/druid/math/expr/ParserTest.java | 6 +
.../tdigestsketch/TDigestSketchUtils.java | 8 +-
.../sql/TDigestGenerateSketchSqlAggregator.java | 10 +-
.../sql/TDigestSketchQuantileSqlAggregator.java | 10 +-
.../hll/sql/HllSketchBaseSqlAggregator.java | 6 +-
.../DoublesSketchApproxQuantileSqlAggregator.java | 13 +-
.../sql/DoublesSketchObjectSqlAggregator.java | 6 +-
.../theta/sql/ThetaSketchBaseSqlAggregator.java | 6 +-
.../hll/sql/HllSketchSqlAggregatorTest.java | 6 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 8 +-
.../bloom/sql/BloomFilterSqlAggregator.java | 19 +-
.../filter/sql/BloomFilterOperatorConversion.java | 8 +-
...FixedBucketsHistogramQuantileSqlAggregator.java | 14 +-
.../histogram/sql/QuantileSqlAggregator.java | 15 +-
.../variance/sql/BaseVarianceSqlAggregator.java | 7 +-
.../druid/query/sql/SleepOperatorConversion.java | 2 +-
.../segment/generator/GeneratorBasicSchemas.java | 7 +
.../druid/segment/virtual/ExpressionPlan.java | 4 +
.../druid/segment/virtual/ExpressionPlanner.java | 11 +-
.../druid/segment/virtual/ExpressionSelectors.java | 16 +-
...gInputCachingExpressionColumnValueSelector.java | 2 +-
.../druid/query/MultiValuedDimensionTest.java | 23 +-
.../druid/segment/generator/SegmentGenerator.java | 69 ++
.../segment/virtual/ExpressionSelectorsTest.java | 330 ++++++++
.../aggregation/builtin/ArraySqlAggregator.java | 4 +-
.../aggregation/builtin/AvgSqlAggregator.java | 5 +-
.../aggregation/builtin/BitwiseSqlAggregator.java | 4 +-
.../BuiltinApproxCountDistinctSqlAggregator.java | 6 +-
.../builtin/EarliestLatestAnySqlAggregator.java | 6 +-
.../aggregation/builtin/GroupingSqlAggregator.java | 6 +-
.../aggregation/builtin/StringSqlAggregator.java | 4 +-
.../expression/BinaryOperatorConversion.java | 57 +-
.../expression/DirectOperatorConversion.java | 11 +-
.../sql/calcite/expression/DruidExpression.java | 457 ++++++++--
.../druid/sql/calcite/expression/Expressions.java | 37 +-
.../calcite/expression/OperatorConversions.java | 76 +-
.../UnaryFunctionOperatorConversion.java | 12 +-
.../expression/UnaryPrefixOperatorConversion.java | 12 +-
.../expression/UnarySuffixOperatorConversion.java | 12 +-
.../builtin/ArrayAppendOperatorConversion.java | 32 +-
.../builtin/ArrayConcatOperatorConversion.java | 32 +-
.../ArrayConstructorOperatorConversion.java | 35 +-
.../builtin/ArrayLengthOperatorConversion.java | 32 +-
.../builtin/ArrayOffsetOfOperatorConversion.java | 32 +-
.../builtin/ArrayOffsetOperatorConversion.java | 32 +-
.../builtin/ArrayOrdinalOfOperatorConversion.java | 32 +-
.../builtin/ArrayOrdinalOperatorConversion.java | 32 +-
.../builtin/ArrayPrependOperatorConversion.java | 32 +-
.../builtin/ArraySliceOperatorConversion.java | 32 +-
.../builtin/ArrayToStringOperatorConversion.java | 32 +-
.../builtin/BTrimOperatorConversion.java | 7 +-
.../expression/builtin/CastOperatorConversion.java | 31 +-
.../expression/builtin/CeilOperatorConversion.java | 6 +-
.../builtin/ConcatOperatorConversion.java | 31 +-
.../builtin/ContainsOperatorConversion.java | 40 +-
.../builtin/DateTruncOperatorConversion.java | 10 +-
.../builtin/FloorOperatorConversion.java | 6 +-
.../HumanReadableFormatOperatorConversion.java | 2 +-
.../expression/builtin/LPadOperatorConversion.java | 9 +-
.../builtin/LTrimOperatorConversion.java | 7 +-
.../expression/builtin/LeftOperatorConversion.java | 7 +-
.../expression/builtin/LikeOperatorConversion.java | 6 +-
.../MultiValueStringOperatorConversions.java | 40 +-
.../MultiValueStringToArrayOperatorConversion.java | 32 +-
.../builtin/ParseLongOperatorConversion.java | 2 +-
.../builtin/PositionOperatorConversion.java | 38 +-
.../builtin/QueryLookupOperatorConversion.java | 2 +-
.../expression/builtin/RPadOperatorConversion.java | 9 +-
.../builtin/RTrimOperatorConversion.java | 7 +-
.../builtin/RegexpExtractOperatorConversion.java | 2 +-
.../builtin/RegexpLikeOperatorConversion.java | 10 +-
.../builtin/RepeatOperatorConversion.java | 7 +-
.../builtin/ReverseOperatorConversion.java | 32 +-
.../builtin/RightOperatorConversion.java | 7 +-
.../builtin/RoundOperatorConversion.java | 12 +-
.../builtin/StringFormatOperatorConversion.java | 2 +-
.../builtin/StringToArrayOperatorConversion.java | 32 +-
.../builtin/StrposOperatorConversion.java | 12 +-
.../builtin/TextcatOperatorConversion.java | 31 +-
.../builtin/TimeArithmeticOperatorConversion.java | 53 +-
.../builtin/TimeCeilOperatorConversion.java | 3 +-
.../builtin/TimeExtractOperatorConversion.java | 7 +-
.../builtin/TimeFloorOperatorConversion.java | 35 +-
.../builtin/TimeFormatOperatorConversion.java | 14 +-
.../builtin/TimeParseOperatorConversion.java | 14 +-
.../builtin/TimeShiftOperatorConversion.java | 16 +-
.../expression/builtin/TrimOperatorConversion.java | 14 +-
.../builtin/TruncateOperatorConversion.java | 14 +-
.../druid/sql/calcite/rel/DruidJoinQueryRel.java | 2 +-
.../apache/druid/sql/calcite/rel/DruidQuery.java | 53 +-
.../apache/druid/sql/calcite/rel/Projection.java | 16 +-
.../sql/calcite/rel/VirtualColumnRegistry.java | 188 ++++-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 38 +-
.../sql/calcite/CalciteCorrelatedQueryTest.java | 21 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 319 +++----
.../calcite/CalciteMultiValueStringQueryTest.java | 71 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 14 +-
.../calcite/expression/ExpressionTestHelper.java | 39 +-
.../sql/calcite/expression/ExpressionsTest.java | 938 ++++++++++++++-------
.../calcite/expression/GreatestExpressionTest.java | 2 +-
.../expression/IPv4AddressMatchExpressionTest.java | 2 +-
.../expression/IPv4AddressParseExpressionTest.java | 2 +-
.../IPv4AddressStringifyExpressionTest.java | 2 +-
.../calcite/expression/LeastExpressionTest.java | 2 +-
.../TimeFormatOperatorConversionTest.java | 4 +-
.../sql/calcite/planner/DruidRexExecutorTest.java | 30 +-
.../druid/sql/calcite/rel/DruidQueryTest.java | 17 +-
.../apache/druid/sql/calcite/rel/GroupingTest.java | 16 +
.../druid/sql/calcite/util/CalciteTestBase.java | 63 ++
111 files changed, 2591 insertions(+), 1538 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org