org.elasticsearch.search.aggregations.AggregationBuilders.sum()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(151)

本文整理了Java中org.elasticsearch.search.aggregations.AggregationBuilders.sum()方法的一些代码示例,展示了AggregationBuilders.sum()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AggregationBuilders.sum()方法的具体详情如下:
包路径:org.elasticsearch.search.aggregations.AggregationBuilders
类名称:AggregationBuilders
方法名:sum

AggregationBuilders.sum介绍

[英]Create a new Sum aggregation with the given name.
[中]使用给定名称创建新的总和聚合。

代码示例

代码示例来源:origin: spring-projects/spring-data-elasticsearch

@Override
public AbstractAggregationBuilder getFacet() {
  Assert.notNull(getName(), "Facet name can't be a null !!!");
  RangeAggregationBuilder rangeBuilder = AggregationBuilders.range(getName());
  final String field = !StringUtils.isEmpty(keyField) ? keyField : this.field;
  rangeBuilder.field(field);
  for (Entry entry : entries) {
    DoubleEntry doubleEntry = (DoubleEntry) entry;
    rangeBuilder.addRange(validateValue(doubleEntry.getFrom(), Double.NEGATIVE_INFINITY), validateValue(doubleEntry.getTo(), Double.POSITIVE_INFINITY));
  }
  rangeBuilder.subAggregation(AggregationBuilders.extendedStats(INTERNAL_STATS).field(field));
  if(!StringUtils.isEmpty(valueField)){
    rangeBuilder.subAggregation(AggregationBuilders.sum(RANGE_INTERNAL_SUM).field(valueField));
  }
  return rangeBuilder;
}

代码示例来源:origin: loklak/loklak_server

/**
 * Get AggregationBuilder to calculate sum, avg and doc count for given classifier.
 * @param classifierName Name of classifier
 * @return AggregationBuilder with required configuration
 */
private static TermsBuilder getClassifierAggregationBuilder(String classifierName) {
  String probabilityField = classifierName + "_probability";
  return AggregationBuilders.terms("by_class").field(classifierName)
    .subAggregation(
      AggregationBuilders.avg("avg_probability").field(probabilityField)
    )
    .subAggregation(
      AggregationBuilders.sum("sum_probability").field(probabilityField)
    );
}

代码示例来源:origin: SonarSource/sonarqube

.minDocCount(1)
.order(Terms.Order.count(false))
.subAggregation(sum(FIELD_DISTRIB_NCLOC).field(FIELD_DISTRIB_NCLOC))));
.subAggregation(sum(NCLOC_KEY + "_filter_sum").field(FIELD_MEASURES_VALUE))));

代码示例来源:origin: NLPchina/elasticsearch-sql

switch (field.getName().toUpperCase()) {
  case "SUM":
    builder = AggregationBuilders.sum(field.getAlias());
    return addFieldToAgg(field, builder);
  case "MAX":

代码示例来源:origin: apache/metron

private TermsAggregationBuilder getGroupsTermBuilder(GroupRequest groupRequest, int index) {
 List<Group> groups = groupRequest.getGroups();
 Group group = groups.get(index);
 String aggregationName = getGroupByAggregationName(group.getField());
 TermsAggregationBuilder termsBuilder = AggregationBuilders.terms(aggregationName);
 termsBuilder
   .field(group.getField())
   .size(accessConfig.getMaxSearchGroups())
   .order(getElasticsearchGroupOrder(group.getOrder()));
 if (index < groups.size() - 1) {
  termsBuilder.subAggregation(getGroupsTermBuilder(groupRequest, index + 1));
 }
 Optional<String> scoreField = groupRequest.getScoreField();
 if (scoreField.isPresent()) {
  SumAggregationBuilder scoreSumAggregationBuilder = AggregationBuilders.sum(getSumAggregationName(scoreField.get())).field(scoreField.get()).missing(0);
  termsBuilder.subAggregation(scoreSumAggregationBuilder);
 }
 return termsBuilder;
}

代码示例来源:origin: Impetus/Kundera

break;
case Expression.SUM:
  aggregationBuilder = AggregationBuilders.sum(function.toParsedText()).field(jPAColumnName);
  break;
case Expression.AVG:

代码示例来源:origin: gitchennan/elasticsearch-query-toolkit

private AbstractAggregationBuilder parseStatsAggregation(SQLAggregateExpr aggExpr, String fieldName) {
    ElasticSqlMethodInvokeHelper.checkStatAggMethod(aggExpr);

    String methodName = aggExpr.getMethodName();
    if (ElasticSqlMethodInvokeHelper.AGG_MIN_METHOD.equalsIgnoreCase(methodName)) {
      return AggregationBuilders.min(String.format("%s_%s", ElasticSqlMethodInvokeHelper.AGG_MIN_METHOD, fieldName)).field(fieldName);
    }

    if (ElasticSqlMethodInvokeHelper.AGG_MAX_METHOD.equalsIgnoreCase(methodName)) {
      return AggregationBuilders.max(String.format("%s_%s", ElasticSqlMethodInvokeHelper.AGG_MAX_METHOD, fieldName)).field(fieldName);
    }

    if (ElasticSqlMethodInvokeHelper.AGG_AVG_METHOD.equalsIgnoreCase(methodName)) {
      return AggregationBuilders.avg(String.format("%s_%s", ElasticSqlMethodInvokeHelper.AGG_AVG_METHOD, fieldName)).field(fieldName);
    }

    if (ElasticSqlMethodInvokeHelper.AGG_SUM_METHOD.equalsIgnoreCase(methodName)) {
      return AggregationBuilders.sum(String.format("%s_%s", ElasticSqlMethodInvokeHelper.AGG_SUM_METHOD, fieldName)).field(fieldName);
    }
    throw new ElasticSql2DslException(String.format("[syntax error] UnSupport agg method call[%s]", methodName));
  }
}

代码示例来源:origin: whiney/springboot-elasticsearch

).addAggregation(
    AggregationBuilders.terms("by_product_code").field("product_code.keyword").size(2000) //按货号分组,最多查500个货号.SKU直接改字段名字就可以
            .subAggregation(AggregationBuilders.sum("quantity").field("quantity"))  //分组计算销量汇总
            .subAggregation(AggregationBuilders.sum("amount").field("amount"))  //分组计算实付款汇总,需要加其他汇总的在这里依次加
            .subAggregation(PipelineAggregatorBuilders.bucketSelector("sales_bucket_filter",script,"quantity"))//查询是否大于指定值
        .order(BucketOrder.aggregation("amount", false))) //分组排序

代码示例来源:origin: Anchormen/sql4es

agg = AggregationBuilders.min(metric.getAggName());
} else if(metric.getOp() == Operation.SUM) {
  agg = AggregationBuilders.sum(metric.getAggName());

代码示例来源:origin: org.sonarsource.sonarqube/sonar-server

.minDocCount(1)
.order(Terms.Order.count(false))
.subAggregation(sum(FIELD_DISTRIB_NCLOC).field(FIELD_DISTRIB_NCLOC))));
.subAggregation(sum(NCLOC_KEY + "_filter_sum").field(FIELD_MEASURES_VALUE))));

代码示例来源:origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

/**
 * Creates an AggregationBuilder for the supplied type
 */
public AggregationBuilder toBuilder(String type) {
  switch (type) {
  case AGG_CARDINALITY:
    return AggregationBuilders.cardinality(getId()).field(getField());
  case AGG_COUNT:
    return AggregationBuilders.count(getId()).field(getField());
  case AGG_SUM:
    return AggregationBuilders.sum(getId()).field(getField());
  case AGG_AVG:
    return AggregationBuilders.avg(getId()).field(getField());
  case AGG_MAX:
    return AggregationBuilders.max(getId()).field(getField());
  case AGG_MIN:
    return AggregationBuilders.min(getId()).field(getField());
  default:
    throw new IllegalArgumentException("Unknown aggregate type: " + type);
  }
}

代码示例来源:origin: org.nlpcn/elasticsearch-sql

switch (field.getName().toUpperCase()) {
  case "SUM":
    builder = AggregationBuilders.sum(field.getAlias());
    return addFieldToAgg(field, builder);
  case "MAX":

代码示例来源:origin: com.impetus.kundera.client/kundera-elastic-search

break;
case Expression.SUM:
  aggregationBuilder = AggregationBuilders.sum(function.toParsedText()).field(jPAColumnName);
  break;
case Expression.AVG:

相关文章