标签：group searchSourceBuilder query result JavaAPI new BZM ES size

public Set<String> queryBzms() {
    Set<String> result = new HashSet<>();
    try {
        // 搜索出成功上报的原始数据
        Object[] objects = new Object[]{};
        // 查询的结果字段,类似于(select id, XSE from ..)
        String[] fields = {"BZM"};
        FetchSourceContext sourceContext = new FetchSourceContext(true, fields, null);
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.boolQuery().must(QueryBuilders.existsQuery("BZM")));
        searchSourceBuilder.fetchSource(sourceContext);
        searchSourceBuilder.aggregation(AggregationBuilders.terms("BZM_group").field("BZM").size(Constant.max_es_size));
        String[] indes = {this.getAliase()};
        SearchRequest searchRequest = new SearchRequest(indes, searchSourceBuilder);
        searchSourceBuilder.size(0);
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        long total = 0;
        Terms terms = searchResponse.getAggregations().get("BZM_group");
        for (Terms.Bucket bucket : terms.getBuckets()) {
            String bzm = bucket.getKeyAsString();
            result.add(bzm);
            total += 1;
        }
        logger.info("-------------- query BZM number by SpecificationEs to success : {} ----------------", total);
    } catch (Exception e){
        logger.error("-------------- query BZM by SpecificationEs to error : {} ----------------", e.getMessage());
    }
    return result;
}

标签：group,searchSourceBuilder,query,result,JavaAPI,new,BZM,ES,size
来源： https://www.cnblogs.com/chaoyou/p/14750196.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。