diff options
| author | Robert Haas <rhaas@postgresql.org> | 2016-03-29 15:04:05 -0400 |
|---|---|---|
| committer | Robert Haas <rhaas@postgresql.org> | 2016-03-29 15:04:05 -0400 |
| commit | 5fe5a2cee91117673e04617aeb1a38e305dcd783 (patch) | |
| tree | 191e937efe0f15daf02c921935d740f429decada /src/backend/optimizer/plan/planner.c | |
| parent | 7f0a2c85fb221bae6908fb2fddad21a4c6d14438 (diff) | |
Allow aggregate transition states to be serialized and deserialized.
This is necessary infrastructure for supporting parallel aggregation
for aggregates whose transition type is "internal". Such values
can't be passed between cooperating processes, because they are
just pointers.
David Rowley, reviewed by Tomas Vondra and by me.
Diffstat (limited to 'src/backend/optimizer/plan/planner.c')
| -rw-r--r-- | src/backend/optimizer/plan/planner.c | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/src/backend/optimizer/plan/planner.c b/src/backend/optimizer/plan/planner.c index 86d80727ed9..b2a9a8088f6 100644 --- a/src/backend/optimizer/plan/planner.c +++ b/src/backend/optimizer/plan/planner.c @@ -3455,7 +3455,8 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumPartialGroups, false, - false)); + false, + true)); else add_partial_path(grouped_rel, (Path *) create_group_path(root, @@ -3496,7 +3497,8 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumPartialGroups, false, - false)); + false, + true)); } } } @@ -3560,7 +3562,8 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumGroups, false, - true)); + true, + false)); } else if (parse->groupClause) { @@ -3626,6 +3629,7 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumGroups, true, + true, true)); else add_path(grouped_rel, (Path *) @@ -3668,7 +3672,8 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumGroups, false, - true)); + true, + false)); } /* @@ -3706,6 +3711,7 @@ create_grouping_paths(PlannerInfo *root, &agg_costs, dNumGroups, true, + true, true)); } } @@ -4039,7 +4045,8 @@ create_distinct_paths(PlannerInfo *root, NULL, numDistinctRows, false, - true)); + true, + false)); } /* Give a helpful error if we failed to find any implementation */ |