private static void searchAgg() {
TermsAggregationBuilder urlAggBuilder = AggregationBuilders.terms("urlAgg").field("url").size(5);
SearchResponse sr = client.prepareSearch(indexname).setQuery(null).addAggregation(urlAggBuilder).execute()
.actionGet();
sr.getAggregations();
Map aggMap = sr.getAggregations().asMap();
StringTerms urlTerms = (StringTerms) aggMap.get("urlAgg");
Iterator urlBucketIt = urlTerms.getBuckets().iterator();
while (urlBucketIt.hasNext()) {
Bucket urlBucket = urlBucketIt.next();
if (!urlBucket.getKey().toString().equals("")) {
if (urlBucket.getDocCount() > 1) {
String url = urlBucket.getKey().toString();
QueryBuilder query = QueryBuilders.matchQuery("url", url);
SearchResponse searchResponse = client.prepareSearch(indexname)
.setTypes(type)
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setQuery(query)
.setSize(50)
.execute().actionGet();
SearchHits hits = searchResponse.getHits();
List idList = new ArrayList();
for (SearchHit hit : hits) {
JSONObject jsonObject = new JSONObject(hit.getSourceAsString());
String current = jsonObject.getString("current_time").toString();
if (current.equals("2017-04-13")) {
idList.add(hit.getId());
}
}
for (int i = 1; i < idList.size(); i++) {
client.prepareDelete("info", "info", idList.get(i)).execute().actionGet();
}
}
}
}
}
ElasticSearch聚合查询
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 博客原文一博客原文二 翻译作品,水平有限,如有错误,烦请留言指正。原文请见 官网英文文档 起步 Elasticse...
- 最近有个日志收集监控的项目采用的技术栈是ELK+JAVA+Spring,客户端语言使用的是Java,以后有机会的话...
- 原文地址:http://www.dotnetcurry.com/aspnet/1354/elastic-searc...