ELK/elasticsearch

java api _search

파아랑새 2019. 1. 25. 17:56

public void doAggr() {

RestHighLevelClient client = new RestHighLevelClient(

        RestClient.builder(

                new HttpHost("192.168.0.106", 9200, "http"),

                new HttpHost("192.168.0.106", 9201, "http")));

// 갯수 count 

SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); 

sourceBuilder.query(QueryBuilders.termQuery("data", "120")); 

sourceBuilder.from(0); 

sourceBuilder.size(5); 

sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS)); 

SearchRequest searchRequest = new SearchRequest();

searchRequest.indices("today190108");

searchRequest.source(sourceBuilder);

try {

SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

System.out.println(searchResponse);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}