Reduce the rescan cost estimate for Materialize nodes to cpu_operator_cost per
authorTom Lane <tgl@sss.pgh.pa.us>
Fri, 19 Feb 2010 21:49:10 +0000 (21:49 +0000)
committerTom Lane <tgl@sss.pgh.pa.us>
Fri, 19 Feb 2010 21:49:10 +0000 (21:49 +0000)
tuple, instead of the former cpu_tuple_cost.  It is sane to charge less than
cpu_tuple_cost because Materialize never does any qual-checking or projection,
so it's got less overhead than most plan node types.  In particular, we want
to have the same charge here as is charged for readout in cost_sort.  That
avoids the problem recently exhibited by Teodor wherein the planner prefers
a useless sort over a materialize step in a context where a lot of rescanning
will happen.  The rescan costs should be just about the same for both node
types, so make their estimates the same.

Not back-patching because all of the current logic for rescan cost estimates
is new in 9.0.  The old handling of rescans is sufficiently not-sane that
changing this in that structure is a bit pointless, and might indeed cause
regressions.

src/backend/optimizer/path/costsize.c
src/backend/optimizer/plan/createplan.c

index f92c944925fa9466ad4538f9d45194cd806772c5..98d60c5ce06a327c00d61bc4cc96afe95c4e91e2 100644 (file)
@@ -59,7 +59,7 @@
  * Portions Copyright (c) 1994, Regents of the University of California
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/optimizer/path/costsize.c,v 1.214 2010/01/05 21:53:58 rhaas Exp $
+ *   $PostgreSQL: pgsql/src/backend/optimizer/path/costsize.c,v 1.215 2010/02/19 21:49:10 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -1189,7 +1189,9 @@ cost_sort(Path *path, PlannerInfo *root,
 
    /*
     * Also charge a small amount (arbitrarily set equal to operator cost) per
-    * extracted tuple.  Note it's correct to use tuples not output_tuples
+    * extracted tuple.  We don't charge cpu_tuple_cost because a Sort node
+    * doesn't do qual-checking or projection, so it has less overhead than
+    * most plan nodes.  Note it's correct to use tuples not output_tuples
     * here --- the upper LIMIT will pro-rate the run cost so we'd be double
     * counting the LIMIT otherwise.
     */
@@ -1222,14 +1224,18 @@ cost_material(Path *path,
    long        work_mem_bytes = work_mem * 1024L;
 
    /*
-    * Whether spilling or not, charge 2x cpu_tuple_cost per tuple to reflect
-    * bookkeeping overhead.  (This rate must be more than cpu_tuple_cost;
+    * Whether spilling or not, charge 2x cpu_operator_cost per tuple to
+    * reflect bookkeeping overhead.  (This rate must be more than what
+    * cost_rescan charges for materialize, ie, cpu_operator_cost per tuple;
     * if it is exactly the same then there will be a cost tie between
     * nestloop with A outer, materialized B inner and nestloop with B outer,
     * materialized A inner.  The extra cost ensures we'll prefer
-    * materializing the smaller rel.)
+    * materializing the smaller rel.)  Note that this is normally a good deal
+    * less than cpu_tuple_cost; which is OK because a Material plan node
+    * doesn't do qual-checking or projection, so it's got less overhead than
+    * most plan nodes.
     */
-   run_cost += 2 * cpu_tuple_cost * tuples;
+   run_cost += 2 * cpu_operator_cost * tuples;
 
    /*
     * If we will spill to disk, charge at the rate of seq_page_cost per page.
@@ -1830,11 +1836,11 @@ cost_mergejoin(MergePath *path, PlannerInfo *root, SpecialJoinInfo *sjinfo)
    bare_inner_cost = inner_run_cost * rescanratio;
    /*
     * When we interpose a Material node the re-fetch cost is assumed to be
-    * just cpu_tuple_cost per tuple, independently of the underlying plan's
-    * cost; but we have to charge an extra cpu_tuple_cost per original fetch
-    * as well.  Note that we're assuming the materialize node will never
-    * spill to disk, since it only has to remember tuples back to the last
-    * mark.  (If there are a huge number of duplicates, our other cost
+    * just cpu_operator_cost per tuple, independently of the underlying
+    * plan's cost; and we charge an extra cpu_operator_cost per original
+    * fetch as well.  Note that we're assuming the materialize node will
+    * never spill to disk, since it only has to remember tuples back to the
+    * last mark.  (If there are a huge number of duplicates, our other cost
     * factors will make the path so expensive that it probably won't get
     * chosen anyway.)  So we don't use cost_rescan here.
     *
@@ -1842,7 +1848,7 @@ cost_mergejoin(MergePath *path, PlannerInfo *root, SpecialJoinInfo *sjinfo)
     * of the generated Material node.
     */
    mat_inner_cost = inner_run_cost +
-       cpu_tuple_cost * inner_path_rows * rescanratio;
+       cpu_operator_cost * inner_path_rows * rescanratio;
 
    /* Prefer materializing if it looks cheaper */
    if (mat_inner_cost < bare_inner_cost)
@@ -2354,10 +2360,8 @@ cost_rescan(PlannerInfo *root, Path *path,
            *rescan_startup_cost = 0;
            *rescan_total_cost = path->total_cost - path->startup_cost;
            break;
-       case T_Material:
        case T_CteScan:
        case T_WorkTableScan:
-       case T_Sort:
            {
                /*
                 * These plan types materialize their final result in a
@@ -2381,6 +2385,33 @@ cost_rescan(PlannerInfo *root, Path *path,
                *rescan_total_cost = run_cost;
            }
            break;
+       case T_Material:
+       case T_Sort:
+           {
+               /*
+                * These plan types not only materialize their results, but
+                * do not implement qual filtering or projection.  So they
+                * are even cheaper to rescan than the ones above.  We charge
+                * only cpu_operator_cost per tuple.  (Note: keep that in
+                * sync with the run_cost charge in cost_sort, and also see
+                * comments in cost_material before you change it.)
+                */
+               Cost    run_cost = cpu_operator_cost * path->parent->rows;
+               double  nbytes = relation_byte_size(path->parent->rows,
+                                                   path->parent->width);
+               long    work_mem_bytes = work_mem * 1024L;
+
+               if (nbytes > work_mem_bytes)
+               {
+                   /* It will spill, so account for re-read cost */
+                   double      npages = ceil(nbytes / BLCKSZ);
+
+                   run_cost += seq_page_cost * npages;
+               }
+               *rescan_startup_cost = 0;
+               *rescan_total_cost = run_cost;
+           }
+           break;
        default:
            *rescan_startup_cost = path->startup_cost;
            *rescan_total_cost = path->total_cost;
index 112c2389d1150c7b75630bb7403d61951ce5ae49..5c35f77ec2d67d9c400c9a07724d5b6e36209bd0 100644 (file)
@@ -10,7 +10,7 @@
  *
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/optimizer/plan/createplan.c,v 1.271 2010/02/12 17:33:20 tgl Exp $
+ *   $PostgreSQL: pgsql/src/backend/optimizer/plan/createplan.c,v 1.272 2010/02/19 21:49:10 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -1703,11 +1703,11 @@ create_mergejoin_plan(PlannerInfo *root,
 
        /*
         * We assume the materialize will not spill to disk, and therefore
-        * charge just cpu_tuple_cost per tuple.  (Keep this estimate in sync
-        * with cost_mergejoin.)
+        * charge just cpu_operator_cost per tuple.  (Keep this estimate in
+        * sync with cost_mergejoin.)
         */
        copy_plan_costsize(matplan, inner_plan);
-       matplan->total_cost += cpu_tuple_cost * matplan->plan_rows;
+       matplan->total_cost += cpu_operator_cost * matplan->plan_rows;
 
        inner_plan = matplan;
    }