Re: [HACKERS] Partition-wise aggregation/grouping
Jeevan Chalke <jeevan.chalke@enterprisedb.com>
On Fri, Mar 2, 2018 at 3:22 AM, Robert Haas <robertmhaas@gmail.com> wrote: > On Thu, Mar 1, 2018 at 5:34 AM, Jeevan Chalke > <jeevan.chalke@enterprisedb.com> wrote: > > Attached new patchset after rebasing my changes over these changes and on > > latest HEAD. > > + * We have already created a Gather or Gather Merge path atop > cheapest > + * partial path. Thus the partial path referenced by the > Gather node needs > + * to be preserved as adding new partial paths in same rel may > delete this > + * referenced path. To do this we need to clear the > partial_pathlist from > + * the partially_grouped_rel as we may add partial paths again > while doing > + * partitionwise aggregation. Keeping older partial path intact > seems > + * reasonable too as it might possible that the final path > chosen which is > + * using it wins, but the underneath partial path is not the > cheapest one. > > This isn't a good design. You shouldn't create a Gather or Gather > Merge node until all partial paths have been added. I mean, the point > is to put a Gather node on top of the cheapest path, not the path that > is currently the cheapest but might not actually be the cheapest once > we've added them all. > To be honest, I didn't know that we should not generated Gather or Gather Merge until we have all possible partial paths in place. I realize it recently while debugging one issue reported by Rajkumar off-list. While working on that fix, what I have observed is - I have cheapest partial path with cost say 10, a Gather on it increased cost to 11. - Later when I add a partial path it has a cost say 9 but a gather on it resulted is total cost to 12. This means, the first Gather path is the cheapest one but not the underneath partial path and unfortunately that got removed when my partial path is added into the partial_pathlist. Due to this, I thought it is better to have both paths valid and to avoid deleting earlier cheapest partial_path, I chose to reset the partially_grouped_rel->partial_pathlist. But, yes per comment in generate_gather_paths() and as you said, we should add Gather or Gather Merge only after we have done with all partial path creation. Sorry for not knowing this before. > > +add_gather_or_gather_merge(PlannerInfo *root, > > Please stop picking generic function names for functions that have > very specific purposes. I don't really think that you need this to be > a separate function at all, but it it is certainly NOT a > general-purpose function for adding a Gather or Gather Merge node. > OK. Got it now. > > + /* > + * Collect statistics about aggregates for estimating costs of > + * performing aggregation in parallel or in partial, if not > already > + * done. We use same cost for all the children as they will be > same > + * anyways. > + */ > > If it only needs to be done once, do we really have to have it inside > the loop? I see that you're using the varno-translated > partial_target->exprs and target->exprs, but if the specific varnos > don't matter, why not just use the untranslated version of the targets > before entering the loop? And if the specific varnos do matter, then > presumably you need to do it every time. > Yes. It can be pulled outside a loop. > > This is not a full review, but I'm out of time for right now. > > -- > Robert Haas > EnterpriseDB: http://www.enterprisedb.com > The Enterprise PostgreSQL Company > -- Jeevan Chalke Technical Architect, Product Development EnterpriseDB Corporation The Enterprise PostgreSQL Company
Commits
-
postgres_fdw: Push down partition-wise aggregation.
- 7e0d64c7a57e 11.0 landed
-
Remove 'target' from GroupPathExtraData.
- c1de1a3a8b93 11.0 landed
-
Implement partition-wise grouping/aggregation.
- e2f1eb0ee30d 11.0 landed
-
Don't pass the grouping target around unnecessarily.
- 94150513ec12 11.0 landed
-
Determine grouping strategies in create_grouping_paths.
- b5996c2791f3 11.0 landed
-
Defer creation of partially-grouped relation until it's needed.
- 4f15e5d09de2 11.0 landed
-
Split create_grouping_paths into degenerate and non-degenerate cases.
- 1466bcfa4a83 11.0 landed
-
Pass additional arguments to a couple of grouping-related functions.
- 648a6c7bd815 11.0 landed
-
Fix logic error in add_paths_to_partial_grouping_rel.
- 3bfe957761ac 11.0 landed
-
Minor cleanup of code related to partially_grouped_rel.
- 5e6a63c0d102 11.0 landed
-
Add a new upper planner relation for partially-aggregated results.
- 3bf05e096b9f 11.0 landed
-
Charge cpu_tuple_cost * 0.5 for Append and MergeAppend nodes.
- 7d8ac9814bc9 11.0 landed
-
Rename enable_partition_wise_join to enable_partitionwise_join
- 2fb1abaeb016 11.0 cited
-
Factor some code out of create_grouping_paths.
- 9fd8b7d63257 11.0 landed
-
Pad XLogReaderState's main_data buffer more aggressively.
- 8735978e7aeb 11.0 cited
-
Prevent int128 from requiring more than MAXALIGN alignment.
- 7518049980be 11.0 cited
-
Fix DROP SUBSCRIPTION hang
- 8edacab20995 11.0 cited
-
Inject $(ICU_LIBS) regardless of platform.
- 66ed3829df95 11.0 cited
-
Some preliminary refactoring towards partitionwise join.
- c44c47a773bd 10.0 cited