groupby_pushdown_multi_table_join_2

englefly · Aug 9, 2024 · 98764d4 · 98764d4
1 parent 117a74e
commit 98764d4
Showing 1 changed file with 18 additions and 15 deletions.
diff --git a/regression-test/data/nereids_rules_p0/eager_aggregate/push_down_count_through_join.out b/regression-test/data/nereids_rules_p0/eager_aggregate/push_down_count_through_join.out
@@ -320,12 +320,13 @@ PhysicalResultSink
 
 -- !groupby_pushdown_multi_table_join_2 --
 PhysicalResultSink
---hashAgg[LOCAL]
-----hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
-------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
---------PhysicalOlapScan[count_t]
+--hashAgg[GLOBAL]
+----hashAgg[LOCAL]
+------hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
+--------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
+----------PhysicalOlapScan[count_t]
+----------PhysicalOlapScan[count_t]
 --------PhysicalOlapScan[count_t]
-------PhysicalOlapScan[count_t]
 
 -- !groupby_pushdown_with_order_by --
 PhysicalResultSink
@@ -572,12 +573,13 @@ SyntaxError:
 
 -- !with_hint_groupby_pushdown_multi_table_join_1 --
 PhysicalResultSink
---hashAgg[LOCAL]
-----hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
-------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
---------PhysicalOlapScan[count_t]
+--hashAgg[GLOBAL]
+----hashAgg[LOCAL]
+------hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
+--------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
+----------PhysicalOlapScan[count_t]
+----------PhysicalOlapScan[count_t]
 --------PhysicalOlapScan[count_t]
-------PhysicalOlapScan[count_t]
 
 Hint log:
 Used:
@@ -908,12 +910,13 @@ SyntaxError:
 
 -- !with_hint_groupby_pushdown_multi_table_join_2 --
 PhysicalResultSink
---hashAgg[LOCAL]
-----hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
-------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
---------PhysicalOlapScan[count_t]
+--hashAgg[GLOBAL]
+----hashAgg[LOCAL]
+------hashJoin[INNER_JOIN] hashCondition=((t1.name = t3.name)) otherCondition=()
+--------hashJoin[INNER_JOIN] hashCondition=((t1.id = t2.id)) otherCondition=()
+----------PhysicalOlapScan[count_t]
+----------PhysicalOlapScan[count_t]
 --------PhysicalOlapScan[count_t]
-------PhysicalOlapScan[count_t]
 
 Hint log:
 Used: