org.elasticsearch.search.aggregations.Aggregation类的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(177)

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

Aggregation介绍

[英]An aggregation. Extends ToXContent as it makes it easier to print out its content.
[中]集合。扩展内容，使其更容易打印出内容。

代码示例

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

  1. public SearchResult(SearchResponse resp, Select select) throws SqlParseException {
  2.   Aggregations aggs = resp.getAggregations();
  3.   if (aggs.get("filter") != null) {
  4.     InternalFilter inf = aggs.get("filter");
  5.     aggs = inf.getAggregations();
  6.   }
  7.   if (aggs.get("group by") != null) {
  8.     InternalTerms terms = aggs.get("group by");
  9.     Collection<Bucket> buckets = terms.getBuckets();
  10.     this.total = buckets.size();
  11.     results = new ArrayList<>(buckets.size());
  12.     for (Bucket bucket : buckets) {
  13.       Map<String, Object> aggsMap = toAggsMap(bucket.getAggregations().getAsMap());
  14.       aggsMap.put("docCount", bucket.getDocCount());
  15.       results.add(aggsMap);
  16.     }
  17.   } else {
  18.     results = new ArrayList<>(1);
  19.     this.total = 1;
  20.     Map<String, Object> map = new HashMap<>();
  21.     for (Aggregation aggregation : aggs) {
  22.       map.put(aggregation.getName(), covenValue(aggregation));
  23.     }
  24.     results.add(map);
  25.   }
  26. }

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

  1. /**
  2.  * Directly write all the aggregations without their bounding object. Used by sub-aggregations (non top level aggs)
  3.  */
  4. public XContentBuilder toXContentInternal(XContentBuilder builder, Params params) throws IOException {
  5.   for (Aggregation aggregation : aggregations) {
  6.     aggregation.toXContent(builder, params);
  7.   }
  8.   return builder;
  9. }

代码示例来源：origin: macrozheng/mall

  1. List<Terms.Bucket> attrIds = ((LongTerms) ((InternalFilter)productAttrs.getProperty("productAttrs")).getAggregations().getProperty("attrIds")).getBuckets();
  2. List<EsProductRelatedInfo.ProductAttr> attrList = new ArrayList<>();
  3. for (Terms.Bucket attrId : attrIds) {

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

  1. assertEquals(aggregation.getName(), agg.getName());
  2. assertEquals(aggregation.getMetaData(), agg.getMetaData());
  3. assertEquals(aggregation.getType(), agg.getType());

代码示例来源：origin: visallo/vertexium

  1. TopHits exactMatchTopHits = b.getAggregations().get(ElasticsearchSearchQueryBase.TOP_HITS_AGGREGATION_NAME);
  2. String mapKey = bucketKeyToString(b.getKey(), exactMatchTopHits);
  3. Map<String, Object> metadata = agg.getMetaData();
  4. if (metadata != null) {
  5.   Object fieldName = metadata.get(ElasticsearchSearchQueryBase.AGGREGATION_METADATA_FIELD_NAME_KEY);

代码示例来源：origin: org.vertexium/vertexium-elasticsearch5

  1. TopHits exactMatchTopHits = b.getAggregations().get(ElasticsearchSearchQueryBase.TOP_HITS_AGGREGATION_NAME);
  2. String mapKey = bucketKeyToString(b.getKey(), exactMatchTopHits);
  3. Map<String, Object> metadata = agg.getMetaData();
  4. if (metadata != null) {
  5.   Object fieldName = metadata.get(ElasticsearchSearchQueryBase.AGGREGATION_METADATA_FIELD_NAME_KEY);

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

  1. private  void handleNumericMetricAggregation(List<String> header, List<String> line, Aggregation aggregation) throws CsvExtractorException {
  2.   String name = aggregation.getName();

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

  1. /**
  2.  * Directly write all the aggregations without their bounding object. Used by sub-aggregations (non top level aggs)
  3.  */
  4. public XContentBuilder toXContentInternal(XContentBuilder builder, Params params) throws IOException {
  5.   for (Aggregation aggregation : aggregations) {
  6.     aggregation.toXContent(builder, params);
  7.   }
  8.   return builder;
  9. }

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

  1. private void handleNumericMetricAggregation(List<String> header, List<Object> line, Aggregation aggregation) throws ObjectResultsExtractException {
  2.   String name = aggregation.getName();

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

  1. /**
  2.  * Directly write all the aggregations without their bounding object. Used by sub-aggregations (non top level aggs)
  3.  */
  4. public XContentBuilder toXContentInternal(XContentBuilder builder, Params params) throws IOException {
  5.   for (Aggregation aggregation : aggregations) {
  6.     aggregation.toXContent(builder, params);
  7.   }
  8.   return builder;
  9. }

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

  1. /**
  2.  * Returns the {@link Aggregation}s keyed by aggregation name.
  3.  */
  4. public final Map<String, Aggregation> getAsMap() {
  5.   if (aggregationsAsMap == null) {
  6.     Map<String, Aggregation> newAggregationsAsMap = new HashMap<>(aggregations.size());
  7.     for (Aggregation aggregation : aggregations) {
  8.       newAggregationsAsMap.put(aggregation.getName(), aggregation);
  9.     }
  10.     this.aggregationsAsMap = unmodifiableMap(newAggregationsAsMap);
  11.   }
  12.   return aggregationsAsMap;
  13. }

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

  1. /**
  2.  * Directly write all the aggregations without their bounding object. Used by sub-aggregations (non top level aggs)
  3.  */
  4. public XContentBuilder toXContentInternal(XContentBuilder builder, Params params) throws IOException {
  5.   for (Aggregation aggregation : aggregations) {
  6.     aggregation.toXContent(builder, params);
  7.   }
  8.   return builder;
  9. }

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

  1. for (Aggregation aggregation : aggregations.aggregations) {
  2.   List<InternalAggregation> aggs = aggByName.computeIfAbsent(
  3.       aggregation.getName(), k -> new ArrayList<>(aggregationsList.size()));
  4.   aggs.add((InternalAggregation)aggregation);

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

  1. @Override
  2. public final InternalAggregation doReduce(Aggregations aggregations, ReduceContext context) {
  3.   preCollection();
  4.   List<String> bucketsPath = AggregationPath.parse(bucketsPaths()[0]).getPathElementsAsStringList();
  5.   for (Aggregation aggregation : aggregations) {
  6.     if (aggregation.getName().equals(bucketsPath.get(0))) {
  7.       List<String> sublistedPath = bucketsPath.subList(1, bucketsPath.size());
  8.       InternalMultiBucketAggregation<?, ?> multiBucketsAgg = (InternalMultiBucketAggregation<?, ?>) aggregation;
  9.       List<? extends InternalMultiBucketAggregation.InternalBucket> buckets = multiBucketsAgg.getBuckets();
  10.       for (InternalMultiBucketAggregation.InternalBucket bucket : buckets) {
  11.         Double bucketValue = BucketHelpers.resolveBucketValue(multiBucketsAgg, bucket, sublistedPath, gapPolicy);
  12.         if (bucketValue != null && !Double.isNaN(bucketValue)) {
  13.           collectBucketValue(bucket.getKeyAsString(), bucketValue);
  14.         }
  15.       }
  16.     }
  17.   }
  18.   return buildAggregation(Collections.emptyList(), metaData());
  19. }

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

  1. /**
  2.  * Returns the {@link Aggregation}s keyed by aggregation name.
  3.  */
  4. public final Map<String, Aggregation> getAsMap() {
  5.   if (aggregationsAsMap == null) {
  6.     Map<String, Aggregation> newAggregationsAsMap = new HashMap<>(aggregations.size());
  7.     for (Aggregation aggregation : aggregations) {
  8.       newAggregationsAsMap.put(aggregation.getName(), aggregation);
  9.     }
  10.     this.aggregationsAsMap = unmodifiableMap(newAggregationsAsMap);
  11.   }
  12.   return aggregationsAsMap;
  13. }

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

  1. /**
  2.  * Returns the {@link Aggregation}s keyed by aggregation name.
  3.  */
  4. public final Map<String, Aggregation> getAsMap() {
  5.   if (aggregationsAsMap == null) {
  6.     Map<String, Aggregation> newAggregationsAsMap = new HashMap<>(aggregations.size());
  7.     for (Aggregation aggregation : aggregations) {
  8.       newAggregationsAsMap.put(aggregation.getName(), aggregation);
  9.     }
  10.     this.aggregationsAsMap = unmodifiableMap(newAggregationsAsMap);
  11.   }
  12.   return aggregationsAsMap;
  13. }

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

  1. /**
  2.  * Returns the {@link Aggregation}s keyed by aggregation name.
  3.  */
  4. public final Map<String, Aggregation> getAsMap() {
  5.   if (aggregationsAsMap == null) {
  6.     Map<String, Aggregation> newAggregationsAsMap = new HashMap<>(aggregations.size());
  7.     for (Aggregation aggregation : aggregations) {
  8.       newAggregationsAsMap.put(aggregation.getName(), aggregation);
  9.     }
  10.     this.aggregationsAsMap = unmodifiableMap(newAggregationsAsMap);
  11.   }
  12.   return aggregationsAsMap;
  13. }

代码示例来源：origin: org.vertexium/vertexium-elasticsearch5

  1. private static Map<String, List<Aggregation>> getAggregationResultsByName(ElasticsearchSearchQueryBase query, Iterable<Aggregation> aggs) {
  2.   Map<String, List<Aggregation>> aggsByName = new HashMap<>();
  3.   if (aggs == null) {
  4.     return aggsByName;
  5.   }
  6.   for (Aggregation agg : aggs) {
  7.     if (agg.getName().equals(ElasticsearchSearchQueryBase.TOP_HITS_AGGREGATION_NAME)) {
  8.       continue;
  9.     }
  10.     String aggName = query.getAggregationName(agg.getName());
  11.     List<Aggregation> l = aggsByName.computeIfAbsent(aggName, k -> new ArrayList<>());
  12.     l.add(agg);
  13.   }
  14.   return aggsByName;
  15. }

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

  1. private static Map<String, List<Aggregation>> getAggregationResultsByName(ElasticSearchSingleDocumentSearchQueryBase query, Iterable<Aggregation> aggs) {
  2.   Map<String, List<Aggregation>> aggsByName = new HashMap<>();
  3.   if (aggs == null) {
  4.     return aggsByName;
  5.   }
  6.   for (Aggregation agg : aggs) {
  7.     String aggName = query.getAggregationName(agg.getName());
  8.     List<Aggregation> l = aggsByName.computeIfAbsent(aggName, k -> new ArrayList<>());
  9.     l.add(agg);
  10.   }
  11.   return aggsByName;
  12. }

代码示例来源：origin: org.vertexium/vertexium-elasticsearch2

  1. private static Map<String, List<Aggregation>> getAggregationResultsByName(ElasticsearchSearchQueryBase query, Iterable<Aggregation> aggs) {
  2.   Map<String, List<Aggregation>> aggsByName = new HashMap<>();
  3.   if (aggs == null) {
  4.     return aggsByName;
  5.   }
  6.   for (Aggregation agg : aggs) {
  7.     String aggName = query.getAggregationName(agg.getName());
  8.     List<Aggregation> l = aggsByName.computeIfAbsent(aggName, k -> new ArrayList<>());
  9.     l.add(agg);
  10.   }
  11.   return aggsByName;
  12. }

内容来源于网络，如有侵权，请联系作者删除！

Aggregation

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com