WindowAgg

说明

在子计划输出的有序分区上计算窗口函数。

核心节点标签

T_WindowAgg

结构化 EXPLAIN 节点类型

WindowAgg

输入

一个满足排序要求的子计划

输出

带窗口函数结果的元组

执行器初始化函数

ExecInitWindowAgg

内存机制

tuplestore

EXPLAIN 名称与属性

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

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

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

内存与临时存储

此节点使用 work_mem 创建 tuplestore。tuplestore 可以将存储的元组移到临时文件，但这不意味着 work_mem 限制了节点的全部内存分配。

tuplestore 已落盘时，交替读写会频繁刷新缓冲区，代价很高。一次性将整个分区存入临时存储会更便宜。

从 tuplestore 读取当前行并保存到 ScanTupleSlot。不能依赖外层计划的输出槽，因为可能需要读取当前行之后的数据。此外，必须将行实际复制出 tuplestore，因为窗口函数求值可能使 tuplestore 将其状态写入磁盘。

窗口函数并非必须调用此函数，但建议在可能时前移标记，以减小 tuplestore 大小并避免将行写入磁盘。

并行执行与运行信息采集

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

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

执行器实现说明

WindowAgg 节点在输入元组集合的适当分区上计算“窗口函数”。每个 WindowAgg 只处理一种窗口定义，但可以计算共享相同窗口定义的多个窗口函数。输入元组必须按排序顺序送达：PARTITION BY 列（如果有）为主要排序键，ORDER BY 列（如果有）为次要排序键。（如果查询包含多种窗口定义，规划器会按需生成多个堆叠的 WindowAgg，并在其间插入 Sort 节点。）

窗口函数可能需要访问当前分区的任意行乃至全部行，因此将分区行累积到元组存储。通过 WindowObject API 调用窗口函数，使其按需访问这些行。

也支持将普通聚合函数用作窗口函数。此时为每个分区模拟常规 Agg 节点环境。按 SQL 规范，输出为该聚合函数在当前行窗口框架内全部行上的结果。

所有窗口函数 API 都使用此对象调用；此对象通过 fcinfo->context 传给窗口函数。

此节点处理的每个窗口函数和窗口聚合都对应一个 WindowStatePerFunc 结构。

核心源码中的 EXPLAIN 标识

case T_WindowAgg:
			pname = sname = "WindowAgg";
			break;

相关条目

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

文档与源码

• src/backend/commands/explain.c:1574
• src/backend/executor/execProcnode.c:345
• src/backend/executor/nodeWindowAgg.c
• src/include/nodes/plannodes.h
• src/backend/utils/sort/tuplestore.c

版本比较

PostgreSQL 17 → 18: 无变化。

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

相关条目

• AggregateAgg
• GroupGroup