ScyllaDB 4.4如何将6个逐分钟分段值平均查询合并为服务端单结果集

• 原生CQL在4.4版本完全不支持UNION集合操作，哪怕是针对同一个分区键的多查询结果合并，也没法通过语法层面直接实现
• 4.4版本没有内置SQL标准窗口函数，无法直接通过窗口分桶完成多时间切片的聚合计算
• 原生AVG聚合仅支持对WHERE条件过滤后的全量结果计算单个聚合值，无法在一次查询中对同范围内的不同时间切片输出独立聚合结果

你需要计算的6个相邻1分钟窗口是连续覆盖最近6分钟的全时间区间，完全可以通过单分区范围扫描+服务端自定义聚合（UDA）的方式，在节点端侧直接完成所有窗口的计算，仅返回最终的6个平均值结果，全程无多次查询往返。

具体实现细节：

• 定义单查询的扫描范围：不需要拆分6个独立时间区间，直接设置查询过滤条件为分区键匹配目标name值，聚簇列timestamp_utc_nanoseconds >= (当前UTC纳秒时间 - 6*60*1e9)。这个范围刚好完整覆盖你需要的6个连续1分钟窗口，和原6个查询的总扫描数据量完全一致。结合当前表的聚簇排序（timestamp_utc_nanoseconds DESC），扫描操作可以直接从聚簇索引的最新数据起始位置开始读，不需要回溯历史旧数据，扫描效率达到最优。
• 部署适配的服务端UDA：
  • 聚合状态初始化：预留6个存储槽位，每个槽位分别记录对应时间窗口的value累计总和、匹配行数，初始值全为0
  • 逐行聚合逻辑：每读取到一行数据，根据该行的时间戳判定它归属哪个1分钟窗口，将value累加到对应槽位的总和字段，对应槽位的计数加1
  • 最终输出逻辑：聚合流程结束后，对每个槽位计算平均值（有匹配行则返回总和/计数，无匹配行则返回空值），按照你需要的列名顺序，组装为包含6个数值字段的tuple结构返回，直接形成单行6列的标准结果集
• 性能表现：由于扫描是针对单分区的范围读取，UDA在存储副本节点本地执行，不需要跨节点数据传输，仅把最终6个平均值序列化返回客户端，网络传输量仅为原始数据的千分之一甚至更低，整体延迟仅相当于1次CQL查询的RTT，远低于6次独立查询的往返开销。

• 利用C#驱动的请求管道把6个查询合并为一次网络往返：虽然能降低网络RTT，但Scylla协调节点仍然要独立执行6次聚合逻辑，总处理开销远高于单扫描+UDA的方案，且返回的是6个独立结果集，需要客户端做二次拼接，不符合服务端返回单结果集的要求
• 一次查询拉取范围内所有原始时间戳、value值到客户端计算：虽然也能做到单次网络往返，但会带来大量的原始数据序列化传输开销，且计算逻辑放在客户端，完全不符合服务端计算的要求
• 尝试在原生CQL语法中写多段带独立时间过滤的聚合：CQL本身不支持在聚合函数中加入独立的过滤条件，这类语法在4.4版本中根本无法执行

内容的提问来源于stack exchange，提问作者Dmitriy G