Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

功能描述


扩展聚合语句中支持“group by level=n”的功能

Group by level语句中可以支持多个聚合函数的存在。


实现方案


接口修改

将FilePathUtils.getPathByLevel()的接口为放到AggregationPlan中,pathIndex作为AggregationPlan的成员。

...

RowRecord mergeRecordByPath(List<AggregateResult> aggResults, Map<String, AggregateResult> finalPaths, Map<Integer, String>pathIndex)



方法逻辑

mergeRecordByPath的参数意义:

  • aggResults为对所有序列进行聚合后的结果列表,即一阶段聚合的结果集。

  • finalPaths的key为最终返回序列名,value为二次聚合计算结果, 需要在该方法中计算得到。

  • pathIndex为一个映射,映射内容为<聚合结果在aggResults列表中的index, 所属的返回序列名>,用于定位一阶段聚合结果在最终聚合结果集中的位置。

...

基本逻辑为:对于aggResults中的每一个聚合结果,从pathIndex中找到对应的最终返回序列,对于位于同一返回序列的聚合结果进行二次聚合操作。二次聚合的操作交由AggregateResult类型计算,见AggregateResult.java中的merge()方法。


结果集 Header修改

修改cli返回的result header

如下图中,改为count(root.ln.wf01..temperature)和count(root.ln.wf02..temperature)

...