database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](Nereids) use join estimation v2 only when stats derive v2 is enable (#13845)

Browse Source 
join estimation V2 should be invoked when enableNereidsStatsDeriveV2=true
This commit is contained in:
minghong
2022-11-01 20:38:39 +08:00
committed by GitHub
parent f0c9867af3
commit 7f34698eef
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/org/apache/doris/nereids/stats/JoinEstimation.java
View File

@ -150,7 +150,7 @@ public class JoinEstimation {
/**
* estimate join
*/
public static StatsDeriveResult estimate(StatsDeriveResult leftStats, StatsDeriveResult rightStats, Join join) {
public static StatsDeriveResult estimateV2(StatsDeriveResult leftStats, StatsDeriveResult rightStats, Join join) {
JoinType joinType = join.getJoinType();
double rowCount = Double.MAX_VALUE;
if (joinType == JoinType.LEFT_SEMI_JOIN || joinType == JoinType.LEFT_ANTI_JOIN) {
@ -196,7 +196,10 @@ public class JoinEstimation {
* Do estimate.
* // TODO: since we have no column stats here. just use a fix ratio to compute the row count.
*/
public static StatsDeriveResult estimate2(StatsDeriveResult leftStats, StatsDeriveResult rightStats, Join join) {
public static StatsDeriveResult estimate(StatsDeriveResult leftStats, StatsDeriveResult rightStats, Join join) {
if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable().enableNereidsStatsDeriveV2) {
return estimateV2(leftStats, rightStats, join);
}
JoinType joinType = join.getJoinType();
// TODO: normalize join hashConjuncts.
// List<Expression> hashJoinConjuncts = join.getHashJoinConjuncts();