zoukankan      html  css  js  c++  java
  • ElasticSearch High Level REST API【7】聚合

    获取平均值聚合示例,最大值、最小值、求和类似

    public void aggregation(){
           RestHighLevelClient client = elasticClient.getRestHighLevelClient();
           SearchRequest searchRequest = new SearchRequest();
           SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
           TermsAggregationBuilder aggregation = AggregationBuilders.terms("by_sex")
                   .field("sex.keyword");   //text类型不能用于索引或排序,必须转成keyword类型
           aggregation.subAggregation(AggregationBuilders.avg("avg_age")
                   .field("age"));  //avg_age 为子聚合名称,名称可随意
           searchSourceBuilder.aggregation(aggregation);
           searchRequest.source(searchSourceBuilder);
           SearchResponse searchResponse = null;
           try {
               searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
           } catch (IOException e) {
               e.printStackTrace();
           }
           Aggregations aggregations = searchResponse.getAggregations();
           Terms byCompanyAggregation = aggregations.get("by_sex");
           Terms.Bucket elasticBucket = byCompanyAggregation.getBucketByKey("女性");
           Avg averageAge = elasticBucket.getAggregations().get("avg_age");
           double avg = averageAge.getValue();
           System.out.println("女性平均年龄:"+avg);
    }

    Stats统计

    public void stats(){
           RestHighLevelClient client = elasticClient.getRestHighLevelClient();
           SearchRequest searchRequest = new SearchRequest();
           SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
           TermsAggregationBuilder aggregation = AggregationBuilders.terms("by_sex")
                   .field("sex.keyword");  //by_sex为聚合名称,名称可随意
           aggregation.subAggregation(AggregationBuilders.stats("stat_age")
                   .field("age"));  //avg_age 为子聚合名称,名称可随意
           searchSourceBuilder.aggregation(aggregation);
           searchRequest.source(searchSourceBuilder);
           SearchResponse searchResponse = null;
           try {
               searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
           } catch (IOException e) {
               e.printStackTrace();
           }
           Aggregations aggregations = searchResponse.getAggregations();
           Terms byCompanyAggregation = aggregations.get("by_sex");
           List<? extends Terms.Bucket> buckets = byCompanyAggregation.getBuckets();
           for (Terms.Bucket bucket : buckets) {
               Stats statAge = bucket.getAggregations().get("stat_age");
               System.out.println(bucket.getKey()); //获取分组名称
               System.out.println("平均值:"+statAge.getAvg());
               System.out.println("总数:"+statAge.getSum());
               System.out.println("最大值:"+statAge.getMaxAsString());
               System.out.println("最小值:"+statAge.getMin());
           }
       }
  • 相关阅读:
    无声的吐槽csdn
    成长
    最近忙的头发都油油的
    pycharm5工具免费分享及安装教程
    分布式版本控制git常见问题之gitignore冲突
    感觉自己还是太年轻,还有很多东西不会
    关于laravel5.2仓库的建立,以及简单调用
    乎,前所未有的挑战!
    嘿嘿,无聊的时候,来点好玩的,翻滚吧,杀马特!!!
    随便说说
  • 原文地址:https://www.cnblogs.com/chentop/p/10313164.html
Copyright © 2011-2022 走看看