如何使用Java API的Elasticsearch FunctionScore查詢

Question

我需要使用Java API實現下面的function_score查詢。我無法找到elasticsearch

{ 
    "size": 40, 
    "query": { 
    "function_score": { 
     "functions": [ 
     { 
      "gauss": { 
      "location": { 
       "origin": { 
       "lat": 39.99606, 
       "lon": 116.480484 
       }, 
       "offset": "2km", 
       "scale": "3km" 
      } 
      } 
     } 
     ], 
     "score_mode": "sum", 
     "boost_mode": "replace", 
     "query": { 
     "bool": { 
      "must": [ 
      { 
       "range": { 
       "startTime": { 
        "from": "2016-04-12T12:00:00.000Z", 
        "to": "2016-04-12T16:00:00.000Z", 
        "include_lower": true, 
        "include_upper": true 
       } 
       } 
      }, 
      { 
       "range": { 
       "endTime": { 
        "from": "2016-04-12T12:00:00.000Z", 
        "to": "2016-04-12T16:00:00.000Z", 
        "include_lower": true, 
        "include_upper": true 
       } 
       } 
      } 
      ] 
     } 
     } 
    } 
    } 
} 

的Java API的節function_score查詢的任何正式文件我使用Java API這樣

RangeQueryBuilder queryStartDate = QueryBuilders.rangeQuery("startTime").gte(param.getStartTime()) 
       .lte(param.getEndTime()); 

     RangeQueryBuilder queryEndDate = QueryBuilders.rangeQuery("endTime").gte(param.getStartTime()) 
       .lte(param.getEndTime()); 

// query 
QueryBuilder querys = QueryBuilders.boolQuery().must(queryStartDate).must(queryEndDate); 

// function 
Map<String, Double> locationMap = new HashMap<String, Double>(); 
     locationMap.put("lat", param.getLat()); 
     locationMap.put("lon", param.getLng()); 
     ScoreFunctionBuilder sfb2 = ScoreFunctionBuilders.gaussDecayFunction("location", locationMap, "1km") 
       .setOffset("2km"); 

//function_score 
FunctionScoreQueryBuilder sa = new FunctionScoreQueryBuilder().boostMode("replace").add(sfb2); 

//final search 
SearchResponse response = client.prepareSearch().setIndices("film").setTypes("data").setQuery(sa) 
       .setQuery(querys).setSize(40).execute().actionGet(); 

，但它沒有作用

Answer 1

您需要若要在您的FunctionScoreQueryBuilder中添加如下產品的查詢：

FunctionScoreQueryBuilder fqBuilder = QueryBuilders.functionScoreQuery(querys); 
    fqBuilder.boostMode(CombineFunction.REPLACE); 
    fqBuilder.scoreMode(ScoreMode.Sum.name().toLowerCase()); 
    fqBuilder.add(sfb2); 
    SearchResponse response = client.prepareSearch().setIndices("film").setTypes("data").setQuery(fqBuilder).setSize(40).execute().actionGet(); 

Answer 2

在Ela sticSearch 5.x這已經改變，並且FunctionScoreQueryBuilder.add（）方法不再存在（已刪除，不推薦使用）。此頁面有一些示例：https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-compound-queries.html#java-query-dsl-function-score-query