3.5 KiB
查询执行
[!WARNING] 本文档描述了Druid如何执行 原生查询，但是由于 Druid SQL 查询被转换为原生查询，因此本文档也适用于SQL运行时。有关如何将SQL查询转换为原生查询的信息，请参阅 SQL查询转换 页面。
Druid的查询执行方法因查询的 数据源类型 而异。
数据源类型
table
直接在 表数据源 上操作的查询使用由Broker进程引导的分散-聚集方法执行。过程如下：
- Broker根据
"interval"参数确定哪些 段 与查询相关。段总是按时间划分的，因此任何间隔与查询间隔重叠的段都可能是相关的。 - 如果输入数据使用
single_dimpartitionsSpec 按范围分区，并且过滤器与用于分区的维度匹配，则Broker还可以根据"filter"进一步修剪段列表。 - Broker在删除了查询的段列表之后，将查询转发到当前为这些段提供服务的数据服务器（如Historical或者运行在MiddleManagers的任务）。
- 对于除 Scan 之外的所有查询类型，数据服务器并行处理每个段，并为每个段生成部分结果。所做的具体处理取决于查询类型。如果启用了 查询缓存，则可以缓存这些部分结果。对于Scan查询，段由单个线程按顺序处理，结果不被缓存。
- Broker从每个数据服务器接收部分结果，将它们合并到最终结果集中，并将它们返回给调用方。对于Timeseries和Scan查询，以及没有排序的GroupBy查询，Broker可以以流式方式执行此操作。否则，Broker将在返回任何内容之前完全计算结果集。
lookup
直接对 Lookup数据源(没有联接) 进行操作的查询使用查询的本地副本在接收查询的Broker上执行。所有注册的Lookup表都预加载到Broker的内存中。查询运行单线程。
使用Lookup作为联接的右端输入的查询的执行是以依赖于其"base"（最左下角）数据源的方式执行的，如下面的 join 部分所述。
union
直接在 union数据源 上操作的查询在Broker上被拆分为属于union的每个表的单独查询。这些查询中的每一个都单独运行，Broker将它们的结果合并在一起。
inline
直接在 内联数据源 上操作的查询在接收查询的Broker上执行。查询运行单线程。
使用内联数据源作为联接的右端输入的查询的执行方式取决于它们的"base"（最左下角）数据源，如下面的 join 部分所述。
query
[query数据源] 是子查询, 每个子查询都被当作它自己的查询来执行, 结果会返回给Broker。然后，Broker继续处理查询的其余部分，就像子查询被内联数据源替换一样。
在大多数情况下，子查询结果在其余查询继续之前在Broker上的内存中完全缓冲，这意味着子查询按顺序执行。以这种方式在给定查询的所有子查询中缓冲的行总数不能超过 druid.server.http.maxSubQueryRows 属性。
有一个例外：如果外部查询和所有子查询都是 groupBy 类型，则可以以流式方式处理子查询结果，并且 druid.server.http.maxSubQueryRows 限制不适用。