Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val multiRequest = new MultiSearchTemplateRequest()
- println("inside multi search")
- //for (searchTerm <- searchTerms) {
- val request = new SearchTemplateRequest()
- request.setRequest(new SearchRequest("common_gisdata_2018q4"))
- request.setScriptType(ScriptType.INLINE)
- request.setScript(
- "{" +
- " "query":{ "geo_shape":{"ogr_geometry":{"shape":{"type":"circle"," +
- " "coordinates":[55.333,25.269],"radius":"1000.0m"},"relation":"intersects"}}}," +
- " "size":1,"sort":[{"_geo_distance":{"ogr_geometrypoint":[[55.333,25.269]],"distance_type":" +
- " "arc","mode":"min","order":"asc","unit":"m"}}],"_source":{"includes":["countryname_ol"," +
- " "emiratestateuno","countryname_en","areaname_en","areaname_ol","countryuno","to_roadspeedlimit"," +
- " "emiratestatename_ol","emiratestatename_en","streetname_ol","streetname_en","from_roadspeedlimit"]}}")
- multiRequest.add(request)
- val response = client.searchTemplate(request, RequestOptions.DEFAULT)
- val searchResponse = response.getResponse
- val multiResponse = client.msearchTemplate(multiRequest, RequestOptions.DEFAULT)
- for (item <- multiResponse.getResponses()) {
- if (item.isFailure()) {
- val error = item.getFailureMessage()
- } else {
- val searchTemplateResponse = item.getResponse()
- val searchResponse = searchTemplateResponse.getResponse()
- val response = searchResponse.getHits().getHits
- for(results <- response) {
- // println(searchResponse.getHits.getHits.toString)
- println(results.getSourceAsString)
- }
- }
- }
- // }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement