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

[feat](Nereids)choose agg mv in cbo #35020

Browse Source
This commit is contained in:
minghong
2024-05-20 10:06:51 +08:00
committed by yiguolei
parent 26d5c50339
commit 518b143caa
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
fe/fe-core/src/main/java/org/apache/doris/nereids/cost/CostModelV1.java
View File

@ -17,6 +17,8 @@
package org.apache.doris.nereids.cost;
import org.apache.doris.catalog.KeysType;
import org.apache.doris.catalog.OlapTable;
import org.apache.doris.nereids.PlanContext;
import org.apache.doris.nereids.properties.DistributionSpec;
import org.apache.doris.nereids.properties.DistributionSpecGather;
@ -97,8 +99,17 @@ class CostModelV1 extends PlanVisitor<Cost, PlanContext> {
@Override
public Cost visitPhysicalOlapScan(PhysicalOlapScan physicalOlapScan, PlanContext context) {
OlapTable table = physicalOlapScan.getTable();
Statistics statistics = context.getStatisticsWithCheck();
return CostV1.ofCpu(context.getSessionVariable(), statistics.getRowCount());
double rows = statistics.getRowCount();
double aggMvBonus = 0.0;
if (table.getBaseIndexId() != physicalOlapScan.getSelectedIndexId()) {
if (table.getIndexMetaByIndexId(physicalOlapScan.getSelectedIndexId())
.getKeysType().equals(KeysType.AGG_KEYS)) {
aggMvBonus = rows > 1.0 ? 1.0 : rows * 0.5;
}
}
return CostV1.ofCpu(context.getSessionVariable(), rows - aggMvBonus);
}
@Override