将这个Elasticsearch查询写成JAVA中调用Elasticsearch的查询代码:GET tmall_order_wide_2023-03-07/_search { "aggs": { "groupbyprovince": { "terms": { "field": "province_name", "size": 40 }, "aggs": { "totalorder": { "sum": { "field": "total_amount" } } } } }, "size": 0 }
时间: 2023-04-06 15:03:33 浏览: 44
以下是Java中调用Elasticsearch的查询代码:
SearchRequest searchRequest = new SearchRequest("tmall_order_wide_2023-03-07");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
TermsAggregationBuilder aggregation = AggregationBuilders.terms("groupbyprovince").field("province_name").size(40)
.subAggregation(AggregationBuilders.sum("totalorder").field("total_amount"));
searchSourceBuilder.aggregation(aggregation);
searchSourceBuilder.size(0);
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
相关问题
将这个Elasticsearch查询写成JAVA中调用Elasticsearch的查询代码:GET tmall_order_wide_2023-03-07/_search { "aggs": { "groupbyskuid": { "terms": { "field": "sku_id", "size": 50 }, "aggs": { "totalskuamount": { "sum": { "field": "total_amount" } } } } }, "size": 0 }
以下是将该Elasticsearch查询写成JAVA中调用Elasticsearch的查询代码的示例:
SearchRequest searchRequest = new SearchRequest("tmall_order_wide_2023-03-07");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("groupbyskuid").field("sku_id").size(50);
SumAggregationBuilder sumAggregationBuilder = AggregationBuilders.sum("totalskuamount").field("total_amount");
aggregationBuilder.subAggregation(sumAggregationBuilder);
searchSourceBuilder.aggregation(aggregationBuilder);
searchSourceBuilder.size(0);
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
将这个Elasticsearch查询写成JAVA中调用Elasticsearch的查询代码:GET tmall_dau_info_2023-03-03/_search { "aggs": { "groupbyisnew": { "terms": { "field": "is_new", "size": 2 } } }, "size": 0 }
以下是Java中调用Elasticsearch的查询代码:
SearchRequest searchRequest = new SearchRequest("tmall_dau_info_2023-03-03");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("groupbyisnew").field("is_new").size(2);
searchSourceBuilder.aggregation(aggregationBuilder);
searchSourceBuilder.size(0);
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
其中,client是Elasticsearch的Java客户端。