本文整理了Java中org.elasticsearch.search.aggregations.AggregationBuilders.count()
方法的一些代码示例,展示了AggregationBuilders.count()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AggregationBuilders.count()
方法的具体详情如下:
包路径:org.elasticsearch.search.aggregations.AggregationBuilders
类名称: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));
内容来源于网络,如有侵权,请联系作者删除!