avgMergeState
描述
MergeState
组合器
可以应用于avg
函数,以合并类型为 AverageFunction(avg, T)
的部分聚合状态并
返回一个新的中间聚合状态。
示例用法
MergeState
组合器对于多层聚合场景尤其有用,在这些场景中,您想要
结合预聚合的状态并将其保持为状态(而不是最终确定它们)以进行后续处理。
为了说明这一点,我们将查看一个示例,其中我们将个别服务器性能指标
转换为跨多个级别的分层聚合:服务器级别 → 区域级别 → 数据中心级别。
首先,我们创建一个表来存储原始数据:
我们将创建一个服务器级别的聚合目标表,并定义一个增量 物化视图作为插入触发器:
我们将在区域和数据中心级别做同样的事情:
然后,我们将向源表插入示例原始数据:
我们将为每个级别编写三个查询:
- 服务级别
- 区域级别
- 数据中心级别
我们可以插入更多数据:
让我们再次检查数据中心级别的性能。请注意整个 聚合链是如何自动更新的: