mirror of
https://git.postgresql.org/git/postgresql.git
synced 2026-02-07 14:27:32 +08:00
a7de3dc5c3
Aggregate nodes now have two new modes: a "partial" mode where they output the unfinalized transition state, and a "finalize" mode where they accept unfinalized transition states rather than individual values as input. These new modes are not used anywhere yet, but they will be necessary for parallel aggregation. The infrastructure also figures to be useful for cases where we want to aggregate local data and remote data via the FDW interface, and want to bring back partial aggregates from the remote side that can then be combined with locally generated partial aggregates to produce the final value. It may also be useful even when neither FDWs nor parallelism are in play, as explained in the comments in nodeAgg.c. David Rowley and Simon Riggs, reviewed by KaiGai Kohei, Heikki Linnakangas, Haribabu Kommi, and me.
63 lines
1.8 KiB
C
63 lines
1.8 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* parse_agg.h
|
|
* handle aggregates and window functions in parser
|
|
*
|
|
* Portions Copyright (c) 1996-2016, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* src/include/parser/parse_agg.h
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef PARSE_AGG_H
|
|
#define PARSE_AGG_H
|
|
|
|
#include "parser/parse_node.h"
|
|
|
|
extern void transformAggregateCall(ParseState *pstate, Aggref *agg,
|
|
List *args, List *aggorder,
|
|
bool agg_distinct);
|
|
|
|
extern Node *transformGroupingFunc(ParseState *pstate, GroupingFunc *g);
|
|
|
|
extern void transformWindowFuncCall(ParseState *pstate, WindowFunc *wfunc,
|
|
WindowDef *windef);
|
|
|
|
extern void parseCheckAggregates(ParseState *pstate, Query *qry);
|
|
|
|
extern List *expand_grouping_sets(List *groupingSets, int limit);
|
|
|
|
extern int get_aggregate_argtypes(Aggref *aggref, Oid *inputTypes);
|
|
|
|
extern Oid resolve_aggregate_transtype(Oid aggfuncid,
|
|
Oid aggtranstype,
|
|
Oid *inputTypes,
|
|
int numArguments);
|
|
|
|
extern void build_aggregate_transfn_expr(Oid *agg_input_types,
|
|
int agg_num_inputs,
|
|
int agg_num_direct_inputs,
|
|
bool agg_variadic,
|
|
Oid agg_state_type,
|
|
Oid agg_input_collation,
|
|
Oid transfn_oid,
|
|
Oid invtransfn_oid,
|
|
Expr **transfnexpr,
|
|
Expr **invtransfnexpr);
|
|
|
|
extern void build_aggregate_combinefn_expr(Oid agg_state_type,
|
|
Oid agg_input_collation,
|
|
Oid combinefn_oid,
|
|
Expr **combinefnexpr);
|
|
|
|
extern void build_aggregate_finalfn_expr(Oid *agg_input_types,
|
|
int num_finalfn_inputs,
|
|
Oid agg_state_type,
|
|
Oid agg_result_type,
|
|
Oid agg_input_collation,
|
|
Oid finalfn_oid,
|
|
Expr **finalfnexpr);
|
|
|
|
#endif /* PARSE_AGG_H */
|