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

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

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

AggregationBuilders.count介绍

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

代码示例

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

return AggregationBuilders.count(field.getAlias()).field(kvValue.toString());
} else {
  return AggregationBuilders.count(field.getAlias()).field(fieldName);

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

AggregationBuilders.terms("branchUuid").field(FIELD_ISSUE_BRANCH_UUID)
 .subAggregation(
  AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY))
 .subAggregation(
  AggregationBuilders.max("maxFuncCreatedAt").field(FIELD_ISSUE_FUNC_CREATED_AT))));

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

private static AggregationBuilder addSecurityReportIssueCountAggregations(AggregationBuilder categoryAggs) {
 return categoryAggs
  .subAggregation(
   AggregationBuilders.filter("vulnerabilities", boolQuery()
    .filter(termQuery(FIELD_ISSUE_TYPE, RuleType.VULNERABILITY.name()))
    .mustNot(existsQuery(FIELD_ISSUE_RESOLUTION)))
    .subAggregation(
     AggregationBuilders.terms("severity").field(FIELD_ISSUE_SEVERITY)
      .subAggregation(
       AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY))))
  .subAggregation(AggregationBuilders.filter("openSecurityHotspots", boolQuery()
   .filter(termQuery(FIELD_ISSUE_TYPE, RuleType.SECURITY_HOTSPOT.name()))
   .mustNot(existsQuery(FIELD_ISSUE_RESOLUTION)))
   .subAggregation(
    AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY)))
  .subAggregation(AggregationBuilders.filter("toReviewSecurityHotspots", boolQuery()
   .filter(termQuery(FIELD_ISSUE_TYPE, RuleType.SECURITY_HOTSPOT.name()))
   .filter(termQuery(FIELD_ISSUE_STATUS, Issue.STATUS_RESOLVED))
   .filter(termQuery(FIELD_ISSUE_RESOLUTION, Issue.RESOLUTION_FIXED)))
   .subAggregation(
    AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY)))
  .subAggregation(AggregationBuilders.filter("wontFixSecurityHotspots", boolQuery()
   .filter(termQuery(FIELD_ISSUE_TYPE, RuleType.SECURITY_HOTSPOT.name()))
   .filter(termQuery(FIELD_ISSUE_STATUS, Issue.STATUS_RESOLVED))
   .filter(termQuery(FIELD_ISSUE_RESOLUTION, Issue.RESOLUTION_WONT_FIX)))
   .subAggregation(
    AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY)));
}

代码示例来源:origin: Graylog2/graylog2-server

searchSourceBuilder.aggregation(AggregationBuilders.count(AGG_VALUE_COUNT).field(field));

代码示例来源:origin: Graylog2/graylog2-server

} else {
  dateHistogramBuilder.subAggregation(AggregationBuilders.count(AGG_VALUE_COUNT).field(field));

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

break;
case Expression.COUNT:
  aggregationBuilder = AggregationBuilders.count(function.toParsedText()).field(jPAColumnName);
  break;

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

/**
 * Create count aggregation.
 *
 * @param field The count function
 * @return AggregationBuilder use to count result
 */
private ValuesSourceAggregationBuilder makeCountAgg(MethodField field) {
  // Cardinality is approximate DISTINCT.
  if ("DISTINCT".equals(field.getOption())) {
    if (field.getParams().size() == 1) {
      return AggregationBuilders.cardinality(field.getAlias()).field(field.getParams().get(0).value.toString());
    } else {
      Integer precision_threshold = (Integer) (field.getParams().get(1).value);
      return AggregationBuilders.cardinality(field.getAlias()).precisionThreshold(precision_threshold).field(field.getParams().get(0).value.toString());
    }
  }
  String fieldName = field.getParams().get(0).value.toString();
  // In case of count(*) we use '_index' as field parameter to count all documents
  if ("*".equals(fieldName)) {
    KVValue kvValue = new KVValue(null, "_index");
    field.getParams().set(0, kvValue);
    return AggregationBuilders.count(field.getAlias()).field(kvValue.toString());
  } else {
    return AggregationBuilders.count(field.getAlias()).field(fieldName);
  }
}

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

AggregationBuilders.terms("branchUuid").field(IssueIndexDefinition.FIELD_ISSUE_BRANCH_UUID)
 .subAggregation(
  AggregationBuilders.count("count").field(IssueIndexDefinition.FIELD_ISSUE_KEY))
 .subAggregation(
  AggregationBuilders.max("maxFuncCreatedAt").field(IssueIndexDefinition.FIELD_ISSUE_FUNC_CREATED_AT))));

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

agg = AggregationBuilders.avg(metric.getAggName());
} else if(addCount && metric.getOp() == Operation.COUNT) {
  agg = AggregationBuilders.count(metric.getAggName());
} else if(metric.getOp() == Operation.MAX) {
  agg = AggregationBuilders.max(metric.getAggName());

代码示例来源:origin: org.graylog2/graylog2-server

.filter(standardAggregationFilters(range, filter));
if (includeCount) {
  searchSourceBuilder.aggregation(AggregationBuilders.count(AGG_VALUE_COUNT).field(field));

代码示例来源: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: com.impetus.kundera.client/kundera-elastic-search

break;
case Expression.COUNT:
  aggregationBuilder = AggregationBuilders.count(function.toParsedText()).field(jPAColumnName);
  break;

代码示例来源:origin: org.graylog2/graylog2-server

} else {
  dateHistogramBuilder.subAggregation(AggregationBuilders.count(AGG_VALUE_COUNT).field(field));

相关文章