Elasticsearch 2.1.1.该指数包含有关运动员跳跃的记录。每个运动员都有几次跳跃尝试。该文档具有以下结构:
{
'event_at' : '2015-01-01T12:12:10', - date of jump
'user_id' : 2142, - athlete’s id
'distance' : 4 - result
}
必须获得以下结果:
{'distance_range' :
{'*-5' : 12, - the number of unique athletes with the maximum jump score in the range from 0 to 5
'6-10': 14,- the number of unique athletes with the maximum jump score in the range from 6 to 10
'11-15': 5 - the number of unique athletes with the maximum jump score in the range from 11 to 15
}
}
我设法获得了每个运动员跳跃分数的最大值,但我不知道如何在更高的水平上获得这个结果。
使用 SQL 可以像这样:
SELECT `distace_range`, count(*) FROM (
SELECT
`user_id`,
IF(MAX(`distace`) <=5,
'*-5',
IF(MAX(`distace`) >= 6 AND MAX(`distace`) >= 10,
'6-10',
'11-15'
)
) `distace_range`
FROM `events`
GROUP BY `user_id`
) t
GROUP BY `distace_range;
我在专门讨论Elasticsearch的官方论坛上发表了一个问题。目前,问题无法通过标准仪器解决,因为对于以下查询:
'aggregations' => [
'distance_range' => [
'terms' => [
'field' => 'doc.user_id',
],
'aggregations' => [
'max_distance' => [
'max' => [
'field' => 'doc.distance'
]
]
]
]
]
在 Elasticsearch 2.1 版本中,没有按范围或术语划分的管道聚合器。
有几种可能的方法可以解决此问题:
- 创建包含最大结果的附加索引
- 使用脚本
- 在客户端对结果求和
我使用了第三种方法。
第一个选项有一个很大的缺点:要有一个相关的附加索引,就必须控制它。因此,我对这个解决方案不满意。
第二个选项也有一些重要的限制:计算的复杂性或对选择的影响会显著影响访问时间。此外,我们必须在多个系统中维护代码。