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