diff options
| author | Robert Haas | 2016-03-29 19:04:05 +0000 |
|---|---|---|
| committer | Robert Haas | 2016-03-29 19:04:05 +0000 |
| commit | 5fe5a2cee91117673e04617aeb1a38e305dcd783 (patch) | |
| tree | 191e937efe0f15daf02c921935d740f429decada /src/include/nodes | |
| 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/include/nodes')
| -rw-r--r-- | src/include/nodes/execnodes.h | 1 | ||||
| -rw-r--r-- | src/include/nodes/plannodes.h | 1 | ||||
| -rw-r--r-- | src/include/nodes/relation.h | 1 |
3 files changed, 3 insertions, 0 deletions
diff --git a/src/include/nodes/execnodes.h b/src/include/nodes/execnodes.h index bf2a09bc39c..dbec07e5a37 100644 --- a/src/include/nodes/execnodes.h +++ b/src/include/nodes/execnodes.h @@ -1836,6 +1836,7 @@ typedef struct AggState bool agg_done; /* indicates completion of Agg scan */ bool combineStates; /* input tuples contain transition states */ bool finalizeAggs; /* should we call the finalfn on agg states? */ + bool serialStates; /* should agg states be (de)serialized? */ int projected_set; /* The last projected grouping set */ int current_set; /* The current grouping set being evaluated */ Bitmapset *grouped_cols; /* grouped cols in current projection */ diff --git a/src/include/nodes/plannodes.h b/src/include/nodes/plannodes.h index 465d72fe890..ea8554f275c 100644 --- a/src/include/nodes/plannodes.h +++ b/src/include/nodes/plannodes.h @@ -712,6 +712,7 @@ typedef struct Agg AggStrategy aggstrategy; /* basic strategy, see nodes.h */ bool combineStates; /* input tuples contain transition states */ bool finalizeAggs; /* should we call the finalfn on agg states? */ + bool serialStates; /* should agg states be (de)serialized? */ int numCols; /* number of grouping columns */ AttrNumber *grpColIdx; /* their indexes in the target list */ Oid *grpOperators; /* equality operators to compare with */ diff --git a/src/include/nodes/relation.h b/src/include/nodes/relation.h index 32f04b25dde..641446ca712 100644 --- a/src/include/nodes/relation.h +++ b/src/include/nodes/relation.h @@ -1296,6 +1296,7 @@ typedef struct AggPath List *qual; /* quals (HAVING quals), if any */ bool combineStates; /* input is partially aggregated agg states */ bool finalizeAggs; /* should the executor call the finalfn? */ + bool serialStates; /* should agg states be (de)serialized? */ } AggPath; /* |