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

AggregationBuilders.max介绍

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

代码示例

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

AggregationBuilders.count(COUNT).field(FIELD_ISSUE_KEY))
     .subAggregation(
      AggregationBuilders.max("maxFuncCreatedAt").field(FIELD_ISSUE_FUNC_CREATED_AT))));
});
SearchResponse response = request.get();

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

final FilterAggregationBuilder builder = AggregationBuilders.filter("agg", QueryBuilders.existsQuery(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.min("ts_min").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.max("ts_max").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.terms("streams").field(Message.FIELD_STREAMS));
final String query = searchSource()

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

return addFieldToAgg(field, builder);
case "MAX":
  builder = AggregationBuilders.max(field.getAlias());
  return addFieldToAgg(field, builder);
case "MIN":

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

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

代码示例来源：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: org.sonarsource.sonarqube/sonar-server

AggregationBuilders.count("count").field(IssueIndexDefinition.FIELD_ISSUE_KEY))
     .subAggregation(
      AggregationBuilders.max("maxFuncCreatedAt").field(IssueIndexDefinition.FIELD_ISSUE_FUNC_CREATED_AT))));
});
SearchResponse response = request.get();

代码示例来源：origin: unchartedsoftware/aperture-tiles

private Map<String, Double> getFieldBoundaries(){
  SearchRequestBuilder boundsRequest = this.client.prepareSearch(this.index)
    .setTypes("datum")
    .setSearchType(SearchType.COUNT)
    .addAggregation(
      AggregationBuilders.min("minX").field(this.xField)
    ).addAggregation(
      AggregationBuilders.min("minY").field(this.yField)
    ).addAggregation(
      AggregationBuilders.max("maxX").field(this.xField)
    ).addAggregation(
      AggregationBuilders.max("maxY").field(this.yField)
    );
  SearchResponse searchResponse = boundsRequest.execute().actionGet();
  Aggregations aggregations = searchResponse.getAggregations();
  Min minX = aggregations.get("minX");
  Min minY = aggregations.get("minY");
  Max maxX = aggregations.get("maxX");
  Max maxY = aggregations.get("maxY");
  Map<String, Double> boundsMap = new HashMap<>();
  boundsMap.put("minX", minX.getValue());
  boundsMap.put("minY", minY.getValue());
  boundsMap.put("maxX", maxX.getValue());
  boundsMap.put("maxY", maxY.getValue());
  return boundsMap;
}

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

.filter(QueryBuilders.existsQuery(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.min("ts_min").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.max("ts_max").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.terms("streams").field(Message.FIELD_STREAMS));
final String query = searchSource()

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

agg = AggregationBuilders.count(metric.getAggName());
} else if(metric.getOp() == Operation.MAX) {
  agg = AggregationBuilders.max(metric.getAggName());
} else if(metric.getOp() == Operation.MIN) {
  agg = AggregationBuilders.min(metric.getAggName());

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

/**
 * Ensures the audit sequence returns an UID greater or equal than the maximum log entry id.
 */
protected void ensureUIDSequencer(ESClient esClient) {
  boolean auditIndexExists = esClient.indexExists(getESIndexName());
  if (!auditIndexExists) {
    return;
  }
  // Get max log entry id
  SearchRequest request = createSearchRequest();
  request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery())
                      .aggregation(AggregationBuilders.max("maxAgg").field("id")));
  SearchResponse searchResponse = esClient.search(request);
  Max agg = searchResponse.getAggregations().get("maxAgg");
  long maxLogEntryId = (long) agg.getValue();
  // Get next sequence id
  UIDGeneratorService uidGeneratorService = Framework.getService(UIDGeneratorService.class);
  UIDSequencer seq = uidGeneratorService.getSequencer();
  seq.init();
  long nextSequenceId = seq.getNextLong(SEQ_NAME);
  // Increment sequence to max log entry id if needed
  if (nextSequenceId < maxLogEntryId) {
    log.info(String.format("Next UID returned by %s sequence is %d, initializing sequence to %d", SEQ_NAME,
        nextSequenceId, maxLogEntryId));
    seq.initSequence(SEQ_NAME, maxLogEntryId);
  }
}

代码示例来源：origin: flaxsearch/BioSolr

.size(start + rows)
.subAggregation(
    AggregationBuilders.max(SCORE_AGGREGATION)
        .script(new Script("_score", ScriptService.ScriptType.INLINE, "expression", null)))
.subAggregation(topHitsBuilder);

代码示例来源：origin: mnemonic-no/act-platform

.size(MAX_RESULT_WINDOW)
.subAggregation(max(MAX_LAST_ADDED_TIMESTAMP_AGGREGATION_NAME)
    .field("timestamp")
.subAggregation(max(MAX_LAST_SEEN_TIMESTAMP_AGGREGATION_NAME)
    .field("lastSeenTimestamp")

代码示例来源：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

return addFieldToAgg(field, builder);
case "MAX":
  builder = AggregationBuilders.max(field.getAlias());
  return addFieldToAgg(field, builder);
case "MIN":

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

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