> ES|QL 的 `FORK` 和 `INLINE STATS` 都已转正：前者把一条查询劈成几路并行跑，后者聚合完还能保住原始行。本文讲清两者的用法、版本状态和各自的使用边界。

## **说明**

本文描述问题及解决方法同样适用于 [腾讯云 Elasticsearch Service（ES）](https://cloud.tencent.com/document/product/845)。

## 它们解决的是同一类问题

ES|QL 有一批命令是在解决同一类问题：**有些事以前要跑多条查询、或者在应用层拼，现在一条就够了**。这篇讲两个都已转正的命令：`FORK` 和 `INLINE STATS`。

## 先看版本，两个都转正了，别按老印象用

| 命令 | 状态 |
|---|---|
| `FORK` | 9.1–9.3 预览，**9.4+ GA**（serverless GA） |
| `INLINE STATS` | 9.2 预览，**9.3+ GA**（serverless GA） |

依据是文档头部的 `applies_to`：[FORK](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L1-L4) 写的是 `stack: preview 9.1-9.3, ga 9.4+`；[INLINE STATS](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L1-L4) 写的是 `stack: preview =9.2, ga 9.3+`。

## 一、FORK：把一条查询劈成几条并行跑

痛点很具体：同一批数据，想同时算几个不同口径，以前只能拆成多条查询各跑一遍，回应用层自己拼。

`FORK` 的定义是（[6–7 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L6-L7)）：创建多个执行分支，对**同一份输入数据**做处理，再把结果合并到一张输出表里。

```esql
FORK ( <processing_commands> ) ( <processing_commands> ) ... ( <processing_commands> )
```

### `_fork` 判别列

合并时会加一列 `_fork`，标明每行来自哪个分支，取值是 `fork1`、`fork2`、`fork3`……按分支定义顺序（[42–43 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L42-L43)）。

### 输出行为

三条要记住（[47–53 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L47-L53)）：

- 各分支**可以输出不同的列**。
- 同名列的类型必须在所有分支里一致，**缺失的列填 `null`**。
- **每个分支内部保持行顺序**，但不同分支的行可能交错。想按分支分组看结果，用 `SORT _fork`。

### 一个很实在的例子

官方有个例子是"一条查询同时拿 Top 5 明细和总数"（[simpleForkWithStats @ v9.5.4](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/generated/x-pack-esql/commands/examples/fork.csv-spec/simpleForkWithStats.md#L3-L19)）：

```esql
FROM books METADATA _score
| WHERE author:"Faulkner"
| EVAL score = round(_score, 2)
| FORK (SORT score DESC, author | LIMIT 5 | KEEP author, score)
       (STATS total = COUNT(*))
| SORT _fork, score DESC, author
```

结果是：

| author:text | score:double | _fork:keyword | total:long |
|---|---|---|---|
| Colleen Faulkner | 2.18 | fork1 | null |
| William Faulkner | 2.18 | fork1 | null |
| Danny Faulkner | 2.02 | fork1 | null |
| Paul Faulkner | 2.02 | fork1 | null |
| William Faulkner | 2.02 | fork1 | null |
| null | null | fork2 | 18 |

`fork1` 是评分最高的 5 本，`fork2` 是总数 18，对不上的列填 `null`。一次性拿回"明细"和"汇总"，不用跑两遍。

### 9.4 起，隐式 LIMIT 没了

这是个重要的行为变化。文档分版本写得很清楚（[25–31 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L25-L31)）：

- **9.1–9.3（预览）**：每个 `FORK` 分支会加一个**隐式的 `LIMIT 1000`**。
- **9.4+（GA）**：`FORK` 分支**不再有隐式 `LIMIT 1000`**。

也就是说，同样一条查询，从 9.3 升到 9.4，每个分支返回的行数上限从 1000 变成了不限。如果你的分支本来就在靠这个隐式 LIMIT 兜底，升级后返回量可能会变大，得自己补上显式的 `LIMIT`。

### 限制

（[57–59 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L57-L59)）

- 最多 **8 个分支**。
- **9.3.0 之前**，`FORK` 不支持配合远端集群引用。
- 一个查询里**只能有一个** `FORK`。

### 另外：FORK 是混合搜索的基础

`FORK` 和 `FUSE` 命令配合，就能做 hybrid search——把多路检索的结果合并起来重新打分（[20 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md#L20)）。比如一个分支走 `match` 全文、一个分支走 kNN 向量，再 `FUSE` 融合。

## 二、INLINE STATS：聚合完还能保住原始行

`STATS` 的问题：聚合之后原始行就没了，只剩分组结果。想给每行带上"本组的平均值""全表的最大值"这种数，以前要么自己再 JOIN 回去，要么查两次。

`INLINE STATS` 补的就是这个。官方定义（[6–10 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L6-L10)）：

> The `INLINE STATS` processing command groups rows according to a common value and calculates one or more aggregated values over the grouped rows. The results are appended as new columns to the input rows.
>
> The command is identical to `STATS` except that it preserves all the columns from the input table.

**跟 `STATS` 一样分组聚合，但结果作为新列追加到原来的行上，行数不变。** 写过 SQL 的话，这个感觉接近窗口函数。

语法（[15–20 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L15-L20)）：

```esql
INLINE STATS [column1 =] expression1 [WHERE boolean_expression1][,
      ...,
      [columnN =] expressionN [WHERE boolean_expressionN]]
      [BY [grouping_name1 =] grouping_expression1[,
          ...,
          [grouping_nameN = ] grouping_expressionN]]
```

注意每个聚合值后面都能跟一个 `WHERE`，用来筛选参与**这个**聚合的行——这是它比 `STATS` 灵活的地方。

### 几个行为要点

（[48–59 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L48-L59)）

- **输出表和输入表行数相同**。
- 只新增列，或者覆盖同名列。列名重叠时，已有列的值可能被覆盖，**列顺序也可能变**——新列会按 `INLINE STATS` 里定义的顺序排。
- 省略 `BY` 就是对全表聚合。
- 分组函数支持 `BUCKET` 和 `TBUCKET`（[68–69 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L68-L69)）。
- 计算聚合时，单个 `null` 值会被跳过（[42 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L42)）。

### 限制

（[107–111 行](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md#L107-L111)）

- 不支持 `CATEGORIZE` 分组函数。
- **`INLINE STATS` 之前不能用 `LIMIT`**（显式或隐式都不行），因为会导致结果不符合预期。
- **`INLINE STATS` 之前不能用 `FORK`**。

第三条正好跟上面 `FORK` 那条对上：虽然 9.4 起 `FORK` 分支不再加隐式 `LIMIT 1000`，但 `v9.5.4` 的文档里这条限制仍然写着，用之前留意一下。

## 三、什么时候用哪个

按我的理解：

- **要把一份数据按不同口径分别算，最后一起看** → `FORK`。典型是"明细 + 汇总"，或者混合搜索的多路召回。
- **要给每一行补一个聚合出来的参照值，行数不能变** → `INLINE STATS`。比如给每条订单补一个"该用户的平均订单金额"。

两者不能串着用（`FORK` 后不能接 `INLINE STATS`），所以别指望"分叉之后再各自补聚合列"。

## 写在最后

这两个命令的共同点是**把原来要在应用层拼的活收回到一条查询里**。用的时候有一件事别忘了：它们都已经转正，但行为在转正过程中改过（比如 `FORK` 分支的隐式 `LIMIT 1000` 在 9.4 没了），别再按老印象写。

**"收回到一条查询里"有什么好处**：以前要做多件事，得发多条查询、在应用层合并结果——**网络往返和应用代码都是成本**。收回之后这些都没了，而且**计算可以由引擎统一优化**。

**但也不是所有情况都该收**：如果各分支的结果要按完全不同的方式处理（比如一边画图、一边导出），合成一条反而让应用逻辑变复杂。**判断依据是"这些结果是不是要一起用"**——一起看就合成一条，各走各的就分开。

**关于 `FORK` 的隐式 LIMIT 被去掉这件事**，我觉得值得提：它说明**转正不等于冻结**。预览期的设计会按实际反馈调整，而这类调整往往不显眼——**你不看 changelog 就会一直按老写法写，然后奇怪为什么结果条数不对**。

**我的建议**：任何预览期用过的功能，转正之后都该**重新确认一次当前行为**。这个习惯成本很低（瞄一眼文档），但能避免一类很隐蔽的问题：**代码没改、查询没改、结果变了**——这种问题排查起来特别费劲，因为你会怀疑数据而不是版本。

## 参考

- [FORK 命令文档 @ v9.5.4](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/fork.md)
- [INLINE STATS 命令文档 @ v9.5.4](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/commands/layout/inlinestats-by.md)
- [FORK 官方示例（simpleForkWithStats）@ v9.5.4](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/generated/x-pack-esql/commands/examples/fork.csv-spec/simpleForkWithStats.md)
- [视图 / 子查询 / FORK 对比 @ v9.5.4](https://github.com/elastic/elasticsearch/blob/v9.5.4/docs/reference/query-languages/esql/_snippets/common/comparing_views_subqueries_fork.md)
- [9.1.0 highlights（FORK 首次发布）@ v9.3.0](https://github.com/elastic/elasticsearch/blob/v9.3.0/docs/release-notes/index.md#L1639-L1663)

> 本文对照 Elasticsearch `v9.5.4` 标签源码与 `v9.3.0` 标签发布说明核对，示例取自官方示例文件。撰写时未启动集群、未运行测试。


ES|QL 的 FORK 和 INLINE STATS 都已转正：前者把一条查询劈成几路并行跑，后者聚合完还能保住原始行。本文讲清两者的用法、版本状态和各自的使用边界。

一条查询做多件事，靠 ES|QL 的 FORK 和 INLINE STATS

ES|QL 的 FORK 和 INLINE STATS 都已转正：前者把一条查询劈成几路并行跑，后者聚合完还能保住原始行。

官方产研

云计算

后端

大数据

ES|QL的FORK和INLINESTATS命令均已转正（GA），分别解决多路并行查询和聚合保留原始行的需求。FORK适用于拆分多口径计算，9.4起移除隐式LIMIT 1000；INLINESTATS适合为每行追加聚合参照值。两者不可串联使用，且转正后行为有变化，需注意版本差异。腾讯云ES同样适用。

代码解释

2026上云采购 | AI焕新·智启新局

bigdata-class

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

一条查询做多件事，靠 ES|QL 的 FORK 和 INLINE STATS-腾讯云开发者社区-腾讯云

一条查询做多件事，靠 ES|QL 的 FORK 和 INLINE STATS

一条查询做多件事，靠 ES|QL 的 FORK 和 INLINE STATS

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐