如何在 Elasticsearch 中聚合位字段?

问题描述

我有一个 60 位(一小时内的分钟数)字段,我想用按位 or 运算符聚合它,以便最终结果有点设置,如果任何贡献值具有位设置。

位域的表示尚未确定,但最好让它稍微紧凑一些,因为有很多记录进入聚合。

假设我们有三个文档,其位域采用二进制值:000110011100。按位 or 聚合会将它们组合到值 1101 - 如果该位设置为任何值,则该位为真。很像总和聚合,但改为按位操作。

我考虑了一个位位置数组(如果设置了位,则位置存在)但它变得有点冗长。

脚本化的指标聚合是可能的,但我对如何实现它有点不知所措。

脚本化的度量聚合看起来像这个破碎的无痛代码

"aggs": {
    "profit": {
      "scripted_metric": {
        "init_script": "minagg = 0L","map_script": "minagg = minagg | minutes",}
   }
 }

感谢您的关注。

解决方法

脚本化指标聚合可处理此问题。使用具有以下映射的索引...

"mappings": {
  "default": {
    "dynamic": "strict","properties": {
      "bitfield": {
        "type": "long"
      }
    }
  }
}

...此聚合提供 or'd 值:

POST /bitfield/_search
{
  "query": {
    "match_all": {}
  },"size": 0,"aggs": {
    "orfield": {
      "scripted_metric": {
        "init_script": "state.agg = 0L","map_script": "state.agg |= doc.bitfield.value","combine_script": "return state.agg","reduce_script": "long total = 0L; for (a in states) {total |= a} return total"
      }
    }
  }
}

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...