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

SearchSourceBuilder.aggregation介绍

[英]Add an get to perform as part of the search.
[中]添加要执行的get作为搜索的一部分。

代码示例

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

.subAggregation(AggregationBuilders.terms("streams").field(Message.FIELD_STREAMS));
final String query = searchSource()
    .aggregation(builder)
    .size(0)
    .toString();

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

searchSourceBuilder.aggregation(AggregationBuilders.count(AGG_VALUE_COUNT).field(field));
  searchSourceBuilder.aggregation(AggregationBuilders.extendedStats(AGG_EXTENDED_STATS).field(field));
  searchSourceBuilder.aggregation(AggregationBuilders.cardinality(AGG_CARDINALITY).field(field));
searchSourceBuilder.aggregation(filterBuilder);

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

public TermsResult terms(String field, List<String> stackedFields, int size, String query, String filter, TimeRange range, Sorting.Direction sorting) {
  final Terms.Order termsOrder = sorting == Sorting.Direction.DESC ? Terms.Order.count(false) : Terms.Order.count(true);
  final SearchSourceBuilder searchSourceBuilder = filteredSearchRequest(query, filter, range);
  searchSourceBuilder.aggregation(createTermsBuilder(field, stackedFields, size, termsOrder));
  searchSourceBuilder.aggregation(AggregationBuilders.missing("missing")
          .field(field));
  final Set<String> affectedIndices = determineAffectedIndices(range, filter);
  if (affectedIndices.isEmpty()) {
    return TermsResult.empty(query, searchSourceBuilder.toString());
  }
  final Search.Builder searchBuilder = new Search.Builder(searchSourceBuilder.toString())
    .ignoreUnavailable(true)
    .allowNoIndices(true)
    .addType(IndexMapping.TYPE_MESSAGE)
    .addIndex(affectedIndices);
  final io.searchbox.core.SearchResult searchResult = wrapInMultiSearch(searchBuilder.build(), () -> "Unable to perform terms query");
  recordEsMetrics(searchResult, range);
  final TermsAggregation termsAggregation = searchResult.getAggregations().getFilterAggregation(AGG_FILTER).getTermsAggregation(AGG_TERMS);
  final MissingAggregation missing = searchResult.getAggregations().getMissingAggregation("missing");
  return new TermsResult(
      termsAggregation,
      missing.getMissing(),
      searchResult.getTotal(),
      query,
      searchSourceBuilder.toString(),
      tookMsFromSearchResult(searchResult),
      // Concat field and stacked fields into one fields list
      ImmutableList.<String>builder().add(field).addAll(stackedFields).build()
  );
}

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

.aggregation(histogramBuilder);

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

searchRequest.source().aggregation(aggregationBuilder);
searchRequest.source().aggregation(aggregatedFacet.getFacet());

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

public HistogramResult histogram(String query, DateHistogramInterval interval, String filter, TimeRange range) {
  final DateHistogramAggregationBuilder histogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
      .field(Message.FIELD_TIMESTAMP)
      .dateHistogramInterval(interval.toESInterval());
  final SearchSourceBuilder searchSourceBuilder = filteredSearchRequest(query, filter, range)
    .aggregation(histogramBuilder);
  final Set<String> affectedIndices = determineAffectedIndices(range, filter);
  if (affectedIndices.isEmpty()) {
    return DateHistogramResult.empty(query, searchSourceBuilder.toString(), interval);
  }
  final Search.Builder searchBuilder = new Search.Builder(searchSourceBuilder.toString())
    .addType(IndexMapping.TYPE_MESSAGE)
    .addIndex(affectedIndices)
    .ignoreUnavailable(true)
    .allowNoIndices(true);
  final io.searchbox.core.SearchResult searchResult = wrapInMultiSearch(searchBuilder.build(), () -> "Unable to retrieve histogram");
  recordEsMetrics(searchResult, range);
  final HistogramAggregation histogramAggregation = searchResult.getAggregations().getHistogramAggregation(AGG_HISTOGRAM);
  return new DateHistogramResult(
    histogramAggregation,
    query,
    searchSourceBuilder.toString(),
    interval,
    tookMsFromSearchResult(searchResult)
  );
}

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

/**
 * Adds an aggregation to the search operation.
 */
public SearchRequestBuilder addAggregation(PipelineAggregationBuilder aggregation) {
  sourceBuilder().aggregation(aggregation);
  return this;
}

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

/**
 * Adds an aggregation to the search operation.
 */
public SearchRequestBuilder addAggregation(AggregationBuilder aggregation) {
  sourceBuilder().aggregation(aggregation);
  return this;
}

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

.aggregation(dateHistogramBuilder);

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

.size(size)
  );
searchSourceBuilder.aggregation(builder);

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

/**
 * Builds a group search request.
 * @param groupRequest The Metron group request.
 * @param queryBuilder The search query.
 * @return An Elasticsearch search request.
 */
private org.elasticsearch.action.search.SearchRequest buildGroupRequest(
  GroupRequest groupRequest,
  QueryBuilder queryBuilder) {
 // handle groups
 TermsAggregationBuilder groups = getGroupsTermBuilder(groupRequest, 0);
 final SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder()
   .query(queryBuilder)
   .aggregation(groups);
 // return the search request
 String[] indices = wildcardIndices(groupRequest.getIndices());
 return new org.elasticsearch.action.search.SearchRequest()
   .indices(indices)
   .source(searchSourceBuilder);
}

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

TermsAggregationBuilder terms = AggregationBuilders.terms( name).field(field);
searchBuilder.aggregation(terms);

代码示例来源：origin: dadoonet/fscrawler

ssb.aggregation(AggregationBuilders.terms(aggregation.getName()).field(aggregation.getField()));

代码示例来源：origin: apache/servicemix-bundles

/**
 * Adds an aggregation to the search operation.
 */
public SearchRequestBuilder addAggregation(PipelineAggregationBuilder aggregation) {
  sourceBuilder().aggregation(aggregation);
  return this;
}

代码示例来源：origin: dadoonet/fscrawler

ssb.aggregation(AggregationBuilders.terms(aggregation.getName()).field(aggregation.getField()));

代码示例来源：origin: dadoonet/fscrawler

ssb.aggregation(AggregationBuilders.terms(aggregation.getName()).field(aggregation.getField()));

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

/**
 * Adds an aggregation to the search operation.
 */
public SearchRequestBuilder addAggregation(PipelineAggregationBuilder aggregation) {
  sourceBuilder().aggregation(aggregation);
  return this;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Adds an aggregation to the search operation.
 */
public SearchRequestBuilder addAggregation(AggregationBuilder aggregation) {
  sourceBuilder().aggregation(aggregation);
  return this;
}

代码示例来源：origin: Thare-Lam/fast-elasticsearch-query-builder

private static void setStatsAggregation(SearchSourceBuilder searchSource, StatsAggregation aggregation,
    Boolean value) {
  if (!value) {
    return;
  }
  StatsAggregationBuilder statsAggregation = new StatsAggregationBuilder(aggregation.name()).field(aggregation.field());
  searchSource.aggregation(statsAggregation);
}

代码示例来源：origin: sirensolutions/siren-join

protected SearchRequest getCardinalityRequest(FilterJoinNode node, ActionRequest parentRequest) {
 String[] lookupIndices = node.getLookupIndices();
 String[] lookupTypes = node.getLookupTypes();
 String lookupPath = node.getLookupPath();
 // Build the search source with the aggregate definition
 SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
 sourceBuilder.size(0).aggregation(AggregationBuilders.cardinality(lookupPath).field(lookupPath));
 // Build search request with reference to the parent request
 SearchRequest searchRequest = new SearchRequest(parentRequest);
 searchRequest.indices(lookupIndices).types(lookupTypes).source(sourceBuilder);
 return searchRequest;
}