use maxPartitionRowCount as rowCount

Signed-off-by: kaijian.ding <[email protected]>
StarRocks · Oct 16, 2024 · 5402e74 · 5402e74
1 parent ff72fdf
commit 5402e74
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/catalog/MaterializedView.java b/fe/fe-core/src/main/java/com/starrocks/catalog/MaterializedView.java
@@ -794,6 +794,14 @@ public long getLastRefreshTime() {
  return refreshScheme.getLastRefreshTime();
  }
 
+ public long getMaxPartitionRowCount() {
+ long maxRowCount = 0;
+ for (Map.Entry<Long, Partition> entry : idToPartition.entrySet()) {
+ maxRowCount = Math.max(maxRowCount, entry.getValue().getBaseIndex().getRowCount());
+ }
+ return maxRowCount;
+ }
+
  /**
  * Check weather this materialized view's staleness is satisfied.
  *

diff --git a/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/MaterializationContext.java b/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/MaterializationContext.java
@@ -362,7 +362,7 @@ private static int orderingIntersectTables(MaterializationContext mvContext) {
  * Prefer small table to large table
  */
  private static long orderingRowCount(MaterializationContext mvContext) {
- return mvContext.getMv().getRowCount();
+ return mvContext.getMv().getMaxPartitionRowCount();
  }
 
  @Override