Aggregate

说明

使用所选分组策略和聚合阶段计算聚合结果。

核心节点标签

T_Agg

结构化 EXPLAIN 节点类型

Aggregate

输入

一个子计划

输出

聚合结果元组

执行器初始化函数

ExecInitAgg

内存机制

aggregate-spill

EXPLAIN 策略

Plain, Sorted, Hashed, Mixed

聚合阶段

Partial, Finalize, Simple

EXPLAIN 名称与属性

结构化格式使用上述 Node Type。文本格式名称还可能包含操作、策略、连接类型、扫描方向或聚合阶段属性。

此源码记录的文本名称：Aggregate, GroupAggregate, HashAggregate, MixedAggregate.

并行感知与并行安全是不同的计划属性。在并行工作进程内运行的节点不一定是并行感知节点。

内存与临时存储

此实现包含哈希聚合的落盘路径。聚合输入排序和转换状态分配各有行为，单一落盘策略不能描述所有聚合策略。

执行哈希聚合时，如果哈希表内存超过限制（见 hash_agg_check_limits()），就进入落盘模式。此模式下，只为哈希表中已有的分组推进转换状态。对于需要新建哈希条目并初始化新转换状态的元组，改为写入磁盘，稍后处理。元组按分区方式落盘，使后续批次更小，更不容易超过 hash_mem；如果某批次仍超出 hash_mem，就必须递归落盘。

落盘数据写入逻辑磁带。与为每次落盘分别使用 BufFile 相比，这样能够更好地控制内存用量、磁盘空间和文件数量。由于算法可能递归，开始时不知道需要多少磁带，因此先分配磁带集合，再按需创建各条磁带。读取磁带时，logtape.c 回收其磁盘空间；读完后将整条磁带销毁。

控制 HashAgg 落盘时创建的分区数。

还会指定每次落盘的最小和最大分区数。分区太少可能反复将相同元组写入磁盘，浪费大量 I/O；分区太多则会用大量内存缓冲落盘文件，而这些内存原本可以用于更大的哈希表。

并行执行与运行信息采集

以下源码回调可以协调执行或收集工作进程的测量数据。回调存在不代表该节点普遍支持共享并行扫描或共享状态。

此构建的回调：ExecAggEstimate, ExecAggInitializeDSM, ExecAggInitializeWorker, ExecAggRetrieveInstrumentation.

同版本手册说明

PostgreSQL 通过分两个阶段进行聚合来支持并行聚合。首先，每个参与查询并行部分的进程执行一个聚合步骤，为该进程所见到的每个分组产生一个部分结果。这在计划中体现为一个 Partial Aggregate 节点。然后，部分结果通过 Gather 或 Gather Merge 传送给领导者。最后，领导者会把来自所有工作进程的结果再次聚合，以产生最终结果。这在计划中体现为一个 Finalize Aggregate 节点。

由于 Finalize Aggregate 节点运行在领导者进程上，因此对于那些相对于输入行数会产生较多分组的查询，查询规划器会认为它不太有利。例如，在最坏情况下， Finalize Aggregate 节点看到的分组数可能与所有工作进程在 Partial Aggregate 阶段看到的输入行数一样多。对于这种情况，使用并行聚合显然不会带来性能收益。查询规划器会在规划过程中考虑这一点，因此在这种场景下不太可能选择并行聚合。

并行聚合并非在所有情况下都受支持。每个聚合都必须是 并行安全 的，并且必须具有合并函数。如果该聚合具有类型为 internal 的转移状态，那么它还必须具有序列化和反序列化函数。更多细节请参见 CREATE AGGREGATE 。如果任何聚合函数调用包含 DISTINCT 或 ORDER BY 子句，则不支持并行聚合。对于有序集聚合，或者当查询涉及 GROUPING SETS 时，也不支持并行聚合。只有当查询涉及的所有连接也都属于计划并行部分时，才能使用并行聚合。

执行器实现说明

ExecAgg 通常按以下步骤求值每个聚合：

transvalue = initcond foreach input_tuple do transvalue = transfunc(transvalue, input_value(s)) result = finalfunc(transvalue, direct_argument(s))

如果未提供 finalfunc，结果就是 transvalue 的最终值。

aggsplit 模式用于支持部分聚合，并可选择其他行为：跳过 finalfunc，使输出始终为最终 transvalue 状态；用 combinefunc 替代 transfunc，以合并从子级部分聚合传来的 transvalue 状态，而非处理原始输入行（选用 combinefunc 时，下文关于 transfunc 的说明同样适用）；对输出应用 serializefunc（仅在跳过 finalfunc 时有意义，因为 serializefunc 处理 transvalue 类型）；对输入应用 deserializefunc（同理，仅在使用 combinefunc 时有意义）。规划器负责正确连接采用这些行为的 Agg 节点，把部分聚合结果交给预期接收它们的节点。

如果普通聚合调用指定了 DISTINCT 或 ORDER BY，我们会先对输入元组排序，并在需要时去重，再执行上文所述的过程。（但有序集聚合不这样处理；对于本模块而言，其 ORDER BY 输入只是普通聚合参数。）这些情况下不支持部分聚合，因为无法保证输入在全局范围内有序或唯一。

核心源码中的 EXPLAIN 标识

case T_Agg:
			{
				Agg		   *agg = (Agg *) plan;

				sname = "Aggregate";
				switch (agg->aggstrategy)
				{
					case AGG_PLAIN:
						pname = "Aggregate";
						strategy = "Plain";
						break;
					case AGG_SORTED:
						pname = "GroupAggregate";
						strategy = "Sorted";
						break;
					case AGG_HASHED:
						pname = "HashAggregate";
						strategy = "Hashed";
						break;
					case AGG_MIXED:
						pname = "MixedAggregate";
						strategy = "Mixed";
						break;
					default:
						pname = "Aggregate ???";
						strategy = "???";
						break;
				}

				if (DO_AGGSPLIT_SKIPFINAL(agg->aggsplit))
				{
					partialmode = "Partial";
					pname = psprintf("%s %s", partialmode, pname);
				}
				else if (DO_AGGSPLIT_COMBINE(agg->aggsplit))
				{
					partialmode = "Finalize";
					pname = psprintf("%s %s", partialmode, pname);
				}
				else
					partialmode = "Simple";
			}
			break;

相关条目

• EXPLAIN
• 使用 EXPLAIN
• 并行计划
• enable_hashagg
• work_mem
• hash_mem_multiplier

文档与源码

• src/backend/commands/explain.c:1531
• src/backend/executor/execProcnode.c:340
• src/backend/executor/nodeAgg.c
• src/include/nodes/plannodes.h
• PostgreSQL 18.6 · parallel-plans

版本比较

PostgreSQL 12 → 13: 属性变化。

以下差异保留原始字段名与英文源描述。

--- PostgreSQL 12
+++ PostgreSQL 13
@@ -1,8 +1,13 @@
 {
   "initializer": "ExecInitAgg",
-  "memory_mechanism": "aggregate",
+  "memory_mechanism": "aggregate-spill",
   "node_tag": "T_Agg",
-  "parallel_callbacks": [],
+  "parallel_callbacks": [
+    "ExecAggEstimate",
+    "ExecAggInitializeDSM",
+    "ExecAggInitializeWorker",
+    "ExecAggRetrieveInstrumentation"
+  ],
   "partial_modes": [
     "Partial",
     "Finalize",

比较已记录的接口与属性，排除来源指纹和构建元数据。某个样本中没有记录，不能据此判断实际引入或移除的版本。

相关条目

• GroupGroup
• WindowAggWindowAgg