?

    public void bucketGroup() {
        SearchRequest request = new SearchRequest();

        /**
         * 查詢條件
         */
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        request.indices("smsp_collect_info_new");
        // 查詢某城市
        searchSourceBuilder.query(QueryBuilders.matchQuery("city", integer));
        // 構建聚合查詢，并統計數量
        //  AggregationBuilders.terms("your_agg_name").field("master_port")，表示對master_port字
        //   段進行聚合，相當于sql group by master_port，其中your_agg_name是我們對聚合字段起的別名
        //  ，到時候我們就可以通過這個別名獲取到聚合的數量
        // AggregationBuilders.count("count_number").field("id"))表示對id字段進行count，就是計數，
        // 其中count_number是我們為計數字段起的別名，同上方一個道理, 此轉換為sql應該是select count(id)
        //    from xx where city=xx group by master_port;
        searchSourceBuilder.aggregation(AggregationBuilders
                .terms("your_agg_name")
                .field("master_port")
                .subAggregation(AggregationBuilders.count("count_number")
                        .field("id")).size(10000));

        //放入文檔中
        request.source(searchSourceBuilder);
        //遠程查詢
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        //元素數量
        SearchHits hits1 = response.getHits();
        // 獲取聚合結果給
        Terms termsAggregation = response.getAggregations().get("your_agg_name");
        // 桶聚合
        for (Terms.Bucket bucket : termsAggregation.getBuckets()) {
        // 獲取聚合的key的值，也就是master_port的每一項的值
            String key = bucket.getKeyAsString();
        // 獲取當前的master_count的聚合的數量
            ValueCount countAggregation = bucket.getAggregations().get("count_number");
            long countValue = countAggregation.getValue();
        }
    }