Advertisement
Guest User

Untitled

a guest
Jul 24th, 2019
85
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.50 KB | None | 0 0
  1. val multiRequest = new MultiSearchTemplateRequest()
  2. println("inside multi search")
  3. //for (searchTerm <- searchTerms) {
  4. val request = new SearchTemplateRequest()
  5. request.setRequest(new SearchRequest("common_gisdata_2018q4"))
  6.  
  7. request.setScriptType(ScriptType.INLINE)
  8. request.setScript(
  9. "{" +
  10. " "query":{ "geo_shape":{"ogr_geometry":{"shape":{"type":"circle"," +
  11. " "coordinates":[55.333,25.269],"radius":"1000.0m"},"relation":"intersects"}}}," +
  12. " "size":1,"sort":[{"_geo_distance":{"ogr_geometrypoint":[[55.333,25.269]],"distance_type":" +
  13. " "arc","mode":"min","order":"asc","unit":"m"}}],"_source":{"includes":["countryname_ol"," +
  14. " "emiratestateuno","countryname_en","areaname_en","areaname_ol","countryuno","to_roadspeedlimit"," +
  15. " "emiratestatename_ol","emiratestatename_en","streetname_ol","streetname_en","from_roadspeedlimit"]}}")
  16.  
  17. multiRequest.add(request)
  18.  
  19. val response = client.searchTemplate(request, RequestOptions.DEFAULT)
  20. val searchResponse = response.getResponse
  21. val multiResponse = client.msearchTemplate(multiRequest, RequestOptions.DEFAULT)
  22.  
  23. for (item <- multiResponse.getResponses()) {
  24. if (item.isFailure()) {
  25. val error = item.getFailureMessage()
  26. } else {
  27. val searchTemplateResponse = item.getResponse()
  28. val searchResponse = searchTemplateResponse.getResponse()
  29. val response = searchResponse.getHits().getHits
  30. for(results <- response) {
  31. // println(searchResponse.getHits.getHits.toString)
  32. println(results.getSourceAsString)
  33. }
  34. }
  35. }
  36. // }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement