Top Hits Aggregation
top_hits 指标聚合器跟踪正在聚合的最相关文档。此聚合器旨在用作子聚合器,以便可以按桶聚合最匹配的文档。
top_hits 聚合器可以有效地用于通过桶聚合器按特定字段对结果集进行分组。一个或多个存储桶聚合器确定结果集被切入的属性。
Options
- from - 要获取的第一个结果的偏移量。
- size - 每个桶返回的最大匹配匹配数的最大数量。默认情况下,返回前三个匹配的结果。
- sort - 如何对顶部匹配的结果进行排序。默认情况下,命中按主查询的分数排序。
Supported per hit features 每个匹配功能支持
top_hits 聚合返回常规搜索命中,因为可以支持许多每个命中功能:
- Highlighting
- Explain
- Named filters and queries
- Source filtering
- Stored fields
- Script fields
- Doc value fields - Include versions
- Include Sequence Numbers and Primary Terms
Example
在以下示例中,我们按类型和每种类型对销售进行分组,以显示上次销售。对于每次销售,只有日期和价格字段包含在来源中。
POST /sales/_search?size=0
{
"aggs": {
"top_tags": {
"terms": {
"field": "type",
"size": 3
},
"aggs": {
"top_sales_hits": {
"top_hits": {
"sort": [
{
"date": {
"order": "desc"
}
}
],
"_source": {
"includes": [ "date", "price" ]
},
"size" : 1
}
}
}
}
}
}
可能的回应:
{
...
"aggregations": {
"top_tags": {
"doc_count_error_upper_bound": 0,
"sum_other_doc_count": 0,
"buckets": [
{
"key": "hat",
"doc_count": 3,
"top_sales_hits": {
"hits": {
"total" : {
"value": 3,
"relation": "eq"
},
"max_score": null,
"hits": [
{
"_index": "sales",
"_type": "_doc",
"_id": "AVnNBmauCQpcRyxw6ChK",
"_source": {
"date": "2015/03/01 00:00:00",
"price": 200
},
"sort": [
1425168000000
],
"_score": null
}
]
}
}
},
{
"key": "t-shirt",
"doc_count": 3,
"top_sales_hits": {
"hits": {
"total" : {
"value": 3,
"relation": "eq"
},
"max_score": null,
"hits": [
{
"_index": "sales",
"_type": "_doc",
"_id": "AVnNBmauCQpcRyxw6ChL",
"_source": {
"date": "2015/03/01 00:00:00",
"price": 175
},
"sort": [
1425168000000
],
"_score": null
}
]
}
}
},
{
"key": "bag",
"doc_count": 1,
"top_sales_hits": {
"hits": {
"total" : {
"value": 1,
"relation": "eq"
},
"max_score": null,
"hits": [
{
"_index": "sales",
"_type": "_doc",
"_id": "AVnNBmatCQpcRyxw6ChH",
"_source": {
"date": "2015/01/01 00:00:00",
"price": 150
},
"sort": [
1420070400000
],
"_score": null
}
]
}
}
}
]
}
}
}
Filed collapse example
字段折叠或结果分组是一种功能,可以将结果集逻辑分组到组中,每组返回顶级文档。组的排序由组中第一个文档的相关性决定。在Elasticsearch中,这可以通过将top_hits聚合器包装为子聚合器的桶聚合器来实现。
在下面的示例中,我们搜索已抓取的网页。对于每个网页,我们存储主体和网页所属的域。通过在域字段上定义术语聚合器,我们按域分组网页的结果集。然后将top_hits聚合器定义为子聚合器,以便每个桶收集最匹配的匹配。
还定义了最大聚合器,其由术语聚合器的订单特征用于通过桶中最相关文档的相关性顺序返回桶。
POST /sales/_search
{
"query": {
"match": {
"body": "elections"
}
},
"aggs": {
"top_sites": {
"terms": {
"field": "domain",
"order": {
"top_hit": "desc"
}
},
"aggs": {
"top_tags_hits": {
"top_hits": {}
},
"top_hit" : {
"max": {
"script": {
"source": "_score"
}
}
}
}
}
}
}
目前需要最大(或最小)聚合器以确保根据每个域的最相关网页的分数来对术语聚合器中的桶进行排序。不幸的是,top_hits聚合器还不能在聚合器术语的顺序选项中使用。
top_hits support in a nested or reverse_nested aggregator
如果top_hits聚合器包装在嵌套或reverse_nested聚合器中,则返回嵌套的命中。嵌套命中在某种意义上是隐藏的迷你文档,它们是常规文档的一部分,在映射中已经配置了嵌套字段类型。如果top_hits聚合器包含在嵌套或reverse_nested聚合器中,则它能够取消隐藏这些文档。阅读有关嵌套类型映射中嵌套的更多信息。
如果已配置嵌套类型,则单个文档实际上被索引为多个Lucene文档,并且它们共享相同的ID。为了确定嵌套命中的身份,需要的不仅仅是id,因此嵌套命中也包括它们的嵌套身份。嵌套标识保存在搜索匹配中的_nested字段下,并包括数组字段和嵌套匹配所属的数组字段中的偏移量。偏移量基于零。
让我们看看它如何与真实样本一起工作。考虑以下映射:
PUT /sales
{
"mappings": {
"properties" : {
"tags" : { "type" : "keyword" },
"comments" : {
"type" : "nested",
"properties" : {
"username" : { "type" : "keyword" },
"comment" : { "type" : "text" }
}
}
}
}
}
comments :注释是一个数组,用于存放产品对象下的嵌套文档。
还有一些文件:
PUT /sales/_doc/1?refresh
{
"tags": ["car", "auto"],
"comments": [
{"username": "baddriver007", "comment": "This car could have better brakes"},
{"username": "dr_who", "comment": "Where's the autopilot? Can't find it"},
{"username": "ilovemotorbikes", "comment": "This car has two extra wheels"}
]
}
现在可以执行以下top_hits聚合(包装在嵌套聚合中):
POST /sales/_search
{
"query": {
"term": { "tags": "car" }
},
"aggs": {
"by_sale": {
"nested" : {
"path" : "comments"
},
"aggs": {
"by_user": {
"terms": {
"field": "comments.username",
"size": 1
},
"aggs": {
"by_nested": {
"top_hits":{}
}
}
}
}
}
}
}
热门命中具有嵌套匹配的响应代码段,它位于数组字段注释的第一个插槽中:
{
...
"aggregations": {
"by_sale": {
"by_user": {
"buckets": [
{
"key": "baddriver007",
"doc_count": 1,
"by_nested": {
"hits": {
"total" : {
"value": 1,
"relation": "eq"
},
"max_score": 0.3616575,
"hits": [
{
"_index": "sales",
"_type" : "_doc",
"_id": "1",
"_nested": {
"field": "comments", #@1
"offset": 0 #@2
},
"_score": 0.3616575,
"_source": {
"comment": "This car could have better brakes", #@3
"username": "baddriver007"
}
}
]
}
}
}
...
]
}
}
}
}
@1: 包含嵌套匹配的数组字段的名称
@2: 如果嵌套命中包含在数组中,则定位
@3: 嵌套命中的来源
如果请求_source,则仅返回嵌套对象的源部分,而不是文档的整个源。嵌套内部对象级别的存储字段也可通过驻留在嵌套或反向嵌入聚合器中的top_hits聚合器访问。
只有嵌套的匹配在命中时会有一个_nested字段,非嵌套(常规)匹配将没有_nested字段。
如果未启用_source,则_nested中的信息也可用于在其他位置解析原始源。
如果在映射中定义了多个级别的嵌套对象类型,则_nested信息也可以是分层的,以便表示深度为两层或更多层的嵌套命中的标识。
在下面的示例中,嵌套的命中位于字段nested_grand_child_field的第一个槽中,然后它位于nested_child_field字段的第二个缓冲区中:
...
"hits": {
"total" : {
"value": 2565,
"relation": "eq"
},
"max_score": 1,
"hits": [
{
"_index": "a",
"_type": "b",
"_id": "1",
"_score": 1,
"_nested" : {
"field" : "nested_child_field",
"offset" : 1,
"_nested" : {
"field" : "nested_grand_child_field",
"offset" : 0
}
}
"_source": ...
},
...
]
}
...