Gather

说明

汇集并行工作进程及参与执行的主进程所产生的元组。

核心节点标签

T_Gather

结构化 EXPLAIN 节点类型

Gather

输入

一个并行子计划

输出

合并后的元组，不保证归并顺序

执行器初始化函数

ExecInitGather

内存机制

unclassified

EXPLAIN 名称与属性

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

此源码记录的文本名称：Gather.

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

内存与临时存储

本次抽取不为此节点设定统一的内存上限或落盘策略。请查看同一构建的实现、相关表达式或提供方。

并行执行与运行信息采集

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

此构建的回调：none extracted from this node implementation.

同版本手册说明

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

执行器实现说明

nodeGather.c：通过多个工作进程扫描计划的支持例程。

Gather 执行器启动并行工作进程，运行一个计划的多个副本。如果工作进程不可用或尚未启动，它也可以自行运行此计划。然后，它将自身和工作进程产生的全部结果合并为单个输出流。因此，Gather 通常用于同时运行多个副本也不会产生重复输出的计划，例如可感知并行的 SeqScan。

另一种配置方式是让 Gather 节点只使用一个工作进程，并设置 single-copy 标志。此时，Gather 让一个工作进程运行计划，自身不执行计划，而是直接返回工作进程产生的元组。如果无法获得工作进程，Gather 会自行运行计划并返回结果。因此，单副本 Gather 节点使用的计划不必具备并行感知能力。

领导进程可能直接访问 ExecProcNode 的结果（need_to_scan_locally 为真时），也可能通过元组队列接收工作进程的结果。因此，不能简单假定在此节点内计算表达式时，元组槽类型始终固定。

没有投影时，结果槽位类型并非显而易见，参见上方注释。

核心源码中的 EXPLAIN 标识

case T_Gather:
			pname = sname = "Gather";
			break;

相关条目

• EXPLAIN
• 使用 EXPLAIN
• 并行计划
• max_parallel_workers_per_gather
• parallel_leader_participation

文档与源码

• src/backend/commands/explain.c:1438
• src/backend/executor/execProcnode.c:355
• src/backend/executor/nodeGather.c
• src/include/nodes/plannodes.h
• PostgreSQL 18.6 · parallel-plans

版本比较

PostgreSQL 17 → 18: 无变化。

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

相关条目

• Gather MergeGatherMerge