aggrTopN

aggrTopN(func, funcArgs, sortingCol, top, [ascending=true])

• func 必须是一个聚合函数。

• funcArgs 是 func 的参数，可以是标量或向量。 func 有多个参数时，它是一个元组。

• sortingCol 是一个数值类型或时间类型的向量，提供 funcArgs 的排序指标。

• top 可以是整数或者浮点数。

  • 如果是整数，表示选取的前 top 行数据；

  • 如果是浮点数，表示百分比，必须小于1.0。根据 funcArgs 的总行数 top 来确定需要选取的行数。若结果不是整数，则向下取整，至少取一行。

• ascending 是一个布尔值，表示是否按升序排序。 默认值是 true。

其他相关 TopN 系列函数参数说明和窗口计算规则请参考: TopN

将 sortingCol 根据 ascending 指定方式进行排序后，得到 funcArgs 中对应的前 top 个元素，使用 func 指定的聚合函数进行计算。sortingCol 包含的 NULL 值当作最小值处理。

aggrTopN(func=sum, funcArgs=1 2 3 4 5, sortingCol=5 1 2 3 4, top=3, ascending=false)
# output
10

aggrTopN(func=corr,funcArgs=[1..5, 3 9 4 2 5], sortingCol=2 3 4 5 3, top=3)
# output
0.052414

top =3，aggrTopN严格取前3个元素进行计算，下例中有3个3对应第三位，只取满足 top 数量的值进行计算

aggrTopN(func=min,funcArgs=1 6 4 -6 4 5, sortingCol=2 3 3 3 4 5, top=3)
# output
1

计算每个股票每天最大交易量前25%的交易平均价格。

t = table(`A`A`A`B`B`B`B`B`B`B`B as sym, 09:30:06 09:30:28 09:31:46 09:31:59 09:30:19 09:30:43 09:31:23 09:31:56 09:30:44 09:31:25 09:31:57 as time, 10 20 10 30 20 40 30 30 30 20 40 as volume, 10.05 10.06 10.07 10.05 20.12 20.13 20.14 20.15 20.12 20.13 20.16 as price);
t;

select aggrTopN(func=avg, funcArgs=price, sortingCol=volume, top=0.25, ascending=false) from t group by sym, time