QueryBuilder boolQueryBuilder = query.getBoolQueryBuilder(localInfoRequest, QueryEnum.termsQuery);
FunctionScoreQueryBuilder.FilterFunctionBuilder[] filterFunctionBuilders = new FunctionScoreQueryBuilder.FilterFunctionBuilder[3];
ScoreFunctionBuilder score = new FieldValueFactorFunctionBuilder(“type”).factor(1.0f);
filterFunctionBuilders[0] = new FunctionScoreQueryBuilder.FilterFunctionBuilder(score);
ScoreFunctionBuilder score1 = new FieldValueFactorFunctionBuilder(“clipId”).factor(1.0f);
filterFunctionBuilders[1] = new FunctionScoreQueryBuilder.FilterFunctionBuilder(score1);
ScoreFunctionBuilder score2 = new FieldValueFactorFunctionBuilder(“partnerId”).factor(1.0f);
filterFunctionBuilders[2] = new FunctionScoreQueryBuilder.FilterFunctionBuilder(score2);
FunctionScoreQueryBuilder functionScoreQuery = QueryBuilders.functionScoreQuery(boolQueryBuilder, filterFunctionBuilders)
.scoreMode(FunctionScoreQuery.ScoreMode.SUM)
.boostMode(CombineFunction.SUM);
System.out.println(functionScoreQuery);
CollapseBuilder collapse = new CollapseBuilder(“partnerId”);
InnerHitBuilder innerHit = new InnerHitBuilder();
innerHit.setName(“collapse”);
innerHit.setFrom(0);
innerHit.setSize(1);
innerHit.setTrackScores(true);
innerHit.setIgnoreUnmapped(true);
innerHit.addSort(SortBuilders.fieldSort(“serviceId”).order(SortOrder.DESC)).addSort(SortBuilders.geoDistanceSort(“point”,30.223,-70.334));
collapse.setInnerHits(innerHit);
SearchSourceBuilder builder = new SearchSourceBuilder()
.query(functionScoreQuery)
.collapse(collapse)
.from(0)
.size(10)
.sort(SortBuilders.fieldSort(“type”).order(SortOrder.DESC))
.sort(SortBuilders.fieldSort(“partnerId”).order(SortOrder.DESC));
System.out.println(builder);
SearchRequest request = new SearchRequest(IndexEnum.LocalInfo.getIndex())
.source(builder)
.searchType(SearchType.QUERY_THEN_FETCH);
SearchResponse response = client.search(request, RequestOptions.DEFAULT);
SearchHit[] hits = response.getHits().getHits();
for (SearchHit hit : hits) {
System.out.println(“Hits”);
System.out.println(hit.getId());
for (SearchHits inner : hit.getInnerHits().values()) {
System.out.println(“InnerHits”);
for (SearchHit innerCollapse : inner.getHits()) {
System.out.println(innerCollapse.getId());
}
}
}
Map<string, searchhits=””> innerHits = hits[0].getInnerHits();
Optional first = innerHits.values().stream().findFirst();
LocalInfo localInfo = JsonUtil.transFormationMap(first.get().getHits()[0].getSourceAsString(), LocalInfo.class);
System.out.println(JsonUtil.transFormationJson(localInfo));
原文地址：http://www.cnblogs.com/qiezi777/p/16877321.html
1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！
2. 分享目的仅供大家学习和交流，请务用于商业用途!
3. 如果你也有好源码或者教程，可以到用户中心发布，分享有积分奖励和额外收入！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，默认解压密码为"gltf",如遇到无法解压的请联系管理员！
8. 因为资源和程序源码均为可复制品，所以不支持任何理由的退款兑现，请斟酌后支付下载
声明：如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性
