[opt](nereids) support pushdown agg distinct through join

xzj7019 · Dec 2, 2024 · bf3e09d · bf3e09d
1 parent b243038
commit bf3e09d
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/.../data/nereids_rules_p0/eager_aggregate/push_down_count_distinct_through_join_one_side.out b/.../data/nereids_rules_p0/eager_aggregate/push_down_count_distinct_through_join_one_side.out
@@ -1,4 +1,21 @@
 -- This file is automatically generated. You should know what you did if you want to edit this
+-- !shape --
+PhysicalResultSink
+--hashAgg[GLOBAL]
+----hashAgg[LOCAL]
+------hashAgg[GLOBAL]
+--------hashAgg[LOCAL]
+----------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
+------------hashAgg[GLOBAL]
+--------------hashAgg[LOCAL]
+----------------PhysicalOlapScan[count_with_distinct_t]
+------------PhysicalOlapScan[count_with_distinct_t]
+
+Hint log:
+Used: use_PUSH_DOWN_AGG_WITH_DISTINCT_THROUGH_JOIN_ONE_SIDE
+UnUsed:
+SyntaxError:
+
 -- !groupby_pushdown_basic --
 1
 1

diff --git a/...es/nereids_rules_p0/eager_aggregate/push_down_count_distinct_through_join_one_side.groovy b/...es/nereids_rules_p0/eager_aggregate/push_down_count_distinct_through_join_one_side.groovy
@@ -49,6 +49,9 @@ suite("push_down_count_distinct_through_join_one_side") {
     sql "insert into count_with_distinct_t values (9, 3, null)"
     sql "insert into count_with_distinct_t values (10, null, null)"
     sql "analyze table count_with_distinct_t with sync;"
+    qt_shape """
+        explain shape plan select /*+use_cbo_rule(PUSH_DOWN_AGG_WITH_DISTINCT_THROUGH_JOIN_ONE_SIDE)*/   count(distinct t1.score) from count_with_distinct_t t1, count_with_distinct_t t2 where t1.id = t2.id group by t1.name;
+    """
     order_qt_groupby_pushdown_basic """
         select /*+use_cbo_rule(PUSH_DOWN_AGG_WITH_DISTINCT_THROUGH_JOIN_ONE_SIDE)*/   count(distinct t1.score) from count_with_distinct_t t1, count_with_distinct_t t2 where t1.id = t2.id group by t1.name;
     """