Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -228,27 +228,3 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
----------PhysicalDistribute[DistributionSpecHash]
------------PhysicalCteConsumer ( cteId=CTEId#0 )

-- !agg_phase4_and_multi_distinct_strategy2 --
PhysicalCteAnchor ( cteId=CTEId#0 )
--PhysicalCteProducer ( cteId=CTEId#0 )
----PhysicalOlapScan[t_gbykey_10_dstkey_10_1000_id_2]
--PhysicalResultSink
----PhysicalDistribute[DistributionSpecGather]
------hashJoin[INNER_JOIN colocated] hashCondition=((gby_key <=> .gby_key)) otherCondition=()
--------hashJoin[INNER_JOIN colocated] hashCondition=((gby_key <=> .gby_key)) otherCondition=()
----------hashAgg[DISTINCT_GLOBAL]
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[DISTINCT_LOCAL]
----------------hashAgg[GLOBAL]
------------------PhysicalDistribute[DistributionSpecHash]
--------------------PhysicalCteConsumer ( cteId=CTEId#0 )
----------hashAgg[DISTINCT_GLOBAL]
------------PhysicalDistribute[DistributionSpecHash]
--------------hashAgg[DISTINCT_LOCAL]
----------------hashAgg[GLOBAL]
------------------PhysicalDistribute[DistributionSpecHash]
--------------------PhysicalCteConsumer ( cteId=CTEId#0 )
--------hashAgg[GLOBAL]
----------PhysicalDistribute[DistributionSpecHash]
------------PhysicalCteConsumer ( cteId=CTEId#0 )

Original file line number Diff line number Diff line change
Expand Up @@ -113,8 +113,11 @@ suite("agg_strategy_variable") {

sql "set agg_phase=4;"
sql "set multi_distinct_strategy=2;"
qt_agg_phase4_and_multi_distinct_strategy2 """explain shape plan
select count(distinct dst_key2), count(distinct dst_key1), max(gby_key),min(gby_key),sum(gby_key),sum0(gby_key),count(gby_key) from t_gbykey_10_dstkey_10_1000_id_2 group by gby_key;"""
explain {
sql "shape plan select count(distinct dst_key2), count(distinct dst_key1), max(gby_key),min(gby_key),sum(gby_key),sum0(gby_key),count(gby_key) from t_gbykey_10_dstkey_10_1000_id_2 group by gby_key;"
contains "PhysicalCteAnchor"
contains "DISTINCT_GLOBAL"
}
sql "set agg_phase=0;"
sql "set multi_distinct_strategy=0;"

Expand Down
Loading