ElasticSearch Javaでの集約操作
3438 ワード
ElasticSearch Javaでの集約操作
適用範囲ElasticSearch 6.x
ElasticSearch 7以上のバージョンの場合は、次のリンクに移動します.
RESTアドバンスドクライアント-DocumentApi:https://blog.csdn.net/u014646662/article/details/96473156
RESTアドバンスドクライアントSearchApi:https://blog.csdn.net/u014646662/article/details/96853830
その他の新しいクエリー方法(ElasticSearch関連ドキュメント):https://blog.csdn.net/u014646662/article/category/8747782
人工知能に興味のある学生は、以下のリンクをクリックすることができます.
現在、人工知能は非常に人気があり、多くの友达が学びたいと思っていますが、一般的なチュートリアルは博碩生のために準備されていて、理解しにくいです.最近、白さんの入門にぴったりのチュートリアルを見つけました.分かりやすいだけでなく、ユーモアもあります.だからみんなに分かち合うことができませんでした.ここをクリックするとチュートリアルにジャンプできます.
https://www.cbedai.net/u014646662
適用範囲ElasticSearch 6.x
ElasticSearch 7以上のバージョンの場合は、次のリンクに移動します.
RESTアドバンスドクライアント-DocumentApi:https://blog.csdn.net/u014646662/article/details/96473156
RESTアドバンスドクライアントSearchApi:https://blog.csdn.net/u014646662/article/details/96853830
その他の新しいクエリー方法(ElasticSearch関連ドキュメント):https://blog.csdn.net/u014646662/article/category/8747782
人工知能に興味のある学生は、以下のリンクをクリックすることができます.
現在、人工知能は非常に人気があり、多くの友达が学びたいと思っていますが、一般的なチュートリアルは博碩生のために準備されていて、理解しにくいです.最近、白さんの入門にぴったりのチュートリアルを見つけました.分かりやすいだけでなく、ユーモアもあります.だからみんなに分かち合うことができませんでした.ここをクリックするとチュートリアルにジャンプできます.
https://www.cbedai.net/u014646662
/**
*
* @throws Exception
*/
@Test
public void max()throws Exception {
Settings settings = Settings.builder().put("cluster.name","my-application").build();
@SuppressWarnings("resource")
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
AggregationBuilder max = AggregationBuilders.max("priceMax").field("price");
SearchResponse sr = client.prepareSearch("lib2").addAggregation(max).get();
Max maxValue = sr.getAggregations().get("priceMax");
System.out.println(maxValue.getValue());
}
/**
*
* @throws Exception
*/
@Test
public void min()throws Exception {
Settings settings = Settings.builder().put("cluster.name","my-application").build();
@SuppressWarnings("resource")
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
AggregationBuilder minAggregationBuilder = AggregationBuilders.min("priceMin").field("price");
SearchResponse sr = client.prepareSearch("lib2").addAggregation(minAggregationBuilder).get();
Min min = sr.getAggregations().get("priceMin");
System.out.println(min.getValue());
}
/**
*
* @throws Exception
*/
@Test
public void avg()throws Exception {
Settings settings = Settings.builder().put("cluster.name","my-application").build();
@SuppressWarnings("resource")
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
AggregationBuilder minAggregationBuilder = AggregationBuilders.avg("numAvg").field("num");
SearchResponse sr = client.prepareSearch("lib2").addAggregation(minAggregationBuilder).get();
Avg avg = sr.getAggregations().get("numAvg");
System.out.println(avg.getValue());
}
/**
*
* @throws Exception
*/
@Test
public void sum()throws Exception {
Settings settings = Settings.builder().put("cluster.name","my-application").build();
@SuppressWarnings("resource")
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
AggregationBuilder minAggregationBuilder = AggregationBuilders.sum("numSum").field("num");
SearchResponse sr = client.prepareSearch("lib2").addAggregation(minAggregationBuilder).get();
Sum sum = sr.getAggregations().get("numSum");
System.out.println(sum.getValue());
}