ES sql查询Java Low Level REST Client

ES sql查询Java Low Level REST Client

@Autowired
RestHighLevelClient restHighLevelClient;

通过高级API获取

restHighLevelClient.getLowLevelClient();

      String method = "GET";
        String endPoint = "/_sql";
        Request request = new Request(method, endPoint);
        request.addParameter("format", "json");
        request.setJsonEntity("{"query":"select * from sourcedata LIMIT 5"}");

        Response response = restHighLevelClient.getLowLevelClient().performRequest(request);
        String result = EntityUtils.toString(response.getEntity());
        System.out.println(result);

 RestClient restClient = RestClient.builder(
               new HttpHost("192.168.5.186", 9200, "http")
        ).build();