每日归档： 2022年7月9日

  var nativeSearchQueryBuilder = new NativeSearchQueryBuilder().withFields("id");
    var queryBuilder = QueryBuilders.boolQuery();
    queryBuilder.must(QueryBuilders.termQuery("phone", "132xxxxxxxdxx"));
    var groupName = "group_aIndex";
    var query =
        nativeSearchQueryBuilder
            .withQuery(queryBuilder)
            .addAggregation(
                AggregationBuilders.terms(groupName)
                    .field("aIndex")
                    .subAggregation(
                        AggregationBuilders.count("count_tId").field("tId")))
            .build();
    var searchHits = elasticsearchOperations.search(query, ESInfo.class);
    var result = searchHits.getAggregations();
    if (result != null) {
      var aggregationMap = result.asMap();
      var parsedLongTerms = (ParsedLongTerms) aggregationMap.get(groupName);
      return parsedLongTerms.getBuckets().stream()
          .map(
              item ->{
                System.out.println(item.getKeyAsNumber().intValue()+","+item.getDocCount())
              }              
          .toList();
    }