[opt](nereids) refine operator estimation

xzj7019 · Sep 23, 2024 · d80fcb3 · d80fcb3
1 parent 1fc65d3
commit d80fcb3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 11 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/FilterEstimation.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/FilterEstimation.java
@@ -626,11 +626,7 @@ private Statistics estimateColumnToConstantRange(Expression leftExpr, DataType d
             double sel = leftRange.getDistinctValues() == 0
                     ? 1.0
                     : intersectRange.getDistinctValues() / leftRange.getDistinctValues();
-            if (sel != 0.0 && sel != 1.0) {
-                sel = Math.max(sel, RANGE_SELECTIVITY_THRESHOLD);
-            } else {
-                sel = DEFAULT_INEQUALITY_COEFFICIENT;
-            }
+            sel = Math.max(sel, RANGE_SELECTIVITY_THRESHOLD);
             sel = getNotNullSelectivity(leftStats.numNulls, context.statistics.getRowCount(), leftStats.ndv, sel);
             updatedStatistics = context.statistics.withSel(sel);
         } else {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
@@ -424,9 +424,7 @@ private Statistics computeOlapScan(OlapScan olapScan) {
                     for (Slot slot : ((Relation) olapScan).getOutput()) {
                         if (derivedStats.findColumnStatistics(slot) == null) {
                             derivedStats.addColumnStats(slot,
-                                    new ColumnStatisticBuilder(ColumnStatistic.UNKNOWN, derivedRowCount)
-                                            //.setAvgSizeByte(slot.getDataType().width())
-                                            .build());
+                                    new ColumnStatisticBuilder(ColumnStatistic.UNKNOWN, derivedRowCount).build());
                         }
                     }
                     return derivedStats;
@@ -453,9 +451,7 @@ private Statistics computeOlapScan(OlapScan olapScan) {
             // get row count from any visible slotReference's colStats
             for (Slot slot : ((Plan) olapScan).getOutput()) {
                 builder.putColumnStatistics(slot,
-                        new ColumnStatisticBuilder(ColumnStatistic.UNKNOWN, tableRowCount)
-                                //.setAvgSizeByte(slot.getDataType().width())
-                                .build());
+                        new ColumnStatisticBuilder(ColumnStatistic.UNKNOWN, tableRowCount).build());
             }
             setHasUnknownColStatsInStatementContext();
             return builder.setRowCount(tableRowCount).build();