概述

聚合函数对一组值进行计算，并返回单个值作为结果。

目前支持纵向聚合，即将来自不同行的一组值聚合成单个值。暂不支持横向聚合，即将来自分组列表值的一组值聚合成单个值。

DISTINCT

函数avg()，count()，max()，min()，sum()，collect_list()，stddev_samp()和stddev_pop()均支持使用集合量词DISTINCT在聚合前对值去重。

Null值

除count(*)外，所有聚合函数在计算时会忽略null值所在行。

示例图集

以下示例根据该图集运行：

avg()

计算一组值的平均值。

MATCH (n)
RETURN avg(n.score)

结果：

FOR item IN [2, "a", 3, "1.2", null]
RETURN avg(item)

结果：

collect_list()

将一组值放入一个列表。

MATCH (n)
RETURN collect_list(n.title)

结果：

count()

返回输入中的总行数。

MATCH (n)
RETURN count(n)

结果：

count(*)

count(*)返回当前工作表中的总行数。

对比以下两条查询，能发现仅在使用count(*)时将null值纳入计算范围：

FOR item IN [1, "a", "2", "b3", null]
RETURN count(item)

结果：

FOR item IN [1, "a", "2", "b3", null]
RETURN count(*)

结果：

count(DISTINCT)

可在count()中加入集合量词DISTINCT来返回输入中不同的行数。

FOR item IN [1, 1, "a", "2", "b3"]
RETURN count(DISTINCT item)

结果：

max()

返回一组值的最大值。

MATCH (n)
RETURN max(n.score)

结果：

FOR item IN [1, "a", "2.1", "b3"]
RETURN max(item)

结果：

min()

返回一组值的最小值。

MATCH (n)
RETURN min(n.score)

结果：

FOR item IN [3, "a", "0.2", "b2"]
RETURN min(item)

结果：

percentile_cont()

计算一组值的连续百分位数。

percentile_cont()的计算步骤如下：

• 升序排列各值。
• 根据公式p = percentile × (n − 1) + 1计算百分位位置，其中n是非null值的总数。
• 利用线性插值法确定百分位数：
  • 若p为整数，则位置p的对应点为百分位数。
  • 若p为介于整数p1和p2之间的小数（p1 < p < p2），则在位置p1的值v1和位置p2的值v2之间插值，根据公式v1 + (p - p1) × (v2 - v1)计算百分位数。

FOR item IN [3, 9, 4, 7, 6]
RETURN percentile_cont(item, 0.4)

结果：

FOR item IN [3, 9, 4, 7, 6]
RETURN percentile_cont(item, 0.5)

结果：

percentile_disc()

计算一组值的离散百分位数。

percentile_disc()的计算步骤如下：

• 升序排列各值。
• 根据公式p = percentile × (n − 1) + 1计算百分位位置，其中n是非null值的总数。
• 确定百分位数：
  • 若p为整数，则位置p对应的点为百分位数。
  • 若p为小数，则抹去p的小数部分取其整数部分p'，位置p'对应的点为百分位数。

FOR item IN [3, 9, 4, 7, 6]
RETURN percentile_disc(item, 0.4)

结果：

FOR item IN [3, 9, 4, 7, 6]
RETURN percentile_disc(item, 0.5)

结果：

stddev_pop()

计算一组值的总体标准差。

MATCH (n)
RETURN stddev_pop(n.score)

结果：

stddev_samp()

计算一组值的样本标准差。

MATCH (n)
RETURN stddev_samp(n.score)

结果：

sum()

计算一组值的总和。

MATCH (n)
RETURN sum(n.score)

结果：

FOR item IN [3, "a", "1.2", "b2"]
RETURN sum(item)

结果：