This is an automated email from the ASF dual-hosted git repository.
zclll pushed a change to branch tpc_preview3
in repository https://gitbox.apache.org/repos/asf/doris.git
from 45209447bad eager agg: 先检查eager_aggregation_mode, 后检查是否下压大join,
保证mode=1 时可以强制下压
add 54c1a37c2b7 [enhance](nereids_rules) Add rewrite rule
DecomposeRepeatWithPreAggregation (#59148)
No new revisions were added by this update.
Summary of changes:
.../org/apache/doris/analysis/VirtualSlotRef.java | 3 -
.../glue/translator/ExpressionTranslator.java | 6 -
.../glue/translator/PhysicalPlanTranslator.java | 27 +-
.../glue/translator/PlanTranslatorContext.java | 25 +-
.../doris/nereids/jobs/executor/Rewriter.java | 4 +-
.../org/apache/doris/nereids/rules/RuleType.java | 2 +-
.../nereids/rules/analysis/CheckAfterRewrite.java | 32 +-
.../nereids/rules/analysis/NormalizeRepeat.java | 51 ++-
.../mv/AbstractMaterializedViewAggregateRule.java | 44 +--
.../nereids/rules/exploration/mv/StructInfo.java | 52 +--
.../LogicalRepeatToPhysicalRepeat.java | 1 +
.../rewrite/DecomposeRepeatWithPreAggregation.java | 352 +++++++++++++++++++++
.../nereids/rules/rewrite/ExprIdRewriter.java | 28 +-
.../nereids/rules/rewrite/SetPreAggStatus.java | 35 +-
.../eageraggregation/PushDownAggContext.java | 1 +
.../eageraggregation/PushdownSumIfAggregation.java | 1 -
.../doris/nereids/stats/ExpressionEstimation.java | 12 +-
.../org/apache/doris/nereids/trees/TreeNode.java | 27 ++
.../nereids/trees/copier/ExpressionDeepCopier.java | 29 --
.../trees/copier/LogicalPlanDeepCopier.java | 4 +-
.../doris/nereids/trees/expressions/Alias.java | 4 +
.../trees/expressions/VirtualSlotReference.java | 170 ----------
.../expressions/functions/scalar/Grouping.java | 2 +-
.../expressions/functions/scalar/GroupingId.java | 2 +-
.../functions/scalar/GroupingScalarFunction.java | 2 +-
.../trees/expressions/functions/udf/JavaUdaf.java | 12 +-
.../trees/expressions/functions/udf/JavaUdf.java | 12 +-
.../trees/expressions/functions/udf/JavaUdtf.java | 12 +-
.../expressions/visitor/ExpressionVisitor.java | 5 -
.../doris/nereids/trees/plans/algebra/Repeat.java | 54 +---
.../nereids/trees/plans/logical/LogicalRepeat.java | 85 +++--
.../plans/physical/PhysicalHashAggregate.java | 10 -
.../trees/plans/physical/PhysicalRepeat.java | 28 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 11 +-
.../org/apache/doris/planner/ResultFileSink.java | 27 --
.../properties/ChildOutputPropertyDeriverTest.java | 9 +
.../DecomposeRepeatWithPreAggregationTest.java | 99 ++++++
.../trees/copier/LogicalPlanDeepCopierTest.java | 4 +
.../decompose_repeat/decompose_repeat.out | 111 +++++++
.../decompose_repeat/decompose_repeat.groovy | 41 +++
40 files changed, 885 insertions(+), 551 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/DecomposeRepeatWithPreAggregation.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/VirtualSlotReference.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/DecomposeRepeatWithPreAggregationTest.java
create mode 100644
regression-test/data/nereids_rules_p0/decompose_repeat/decompose_repeat.out
create mode 100644
regression-test/suites/nereids_rules_p0/decompose_repeat/decompose_repeat.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
