java操作elasticsearch实现聚合查询

时间:2021-10-28 10:15:26

1、max 最大值

//max 求最大值
@Test
public void test30() throws UnknownHostException{
//1、指定es集群 cluster.name 是固定的key值,my-application是ES集群的名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
//2.创建访问ES服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
//aggMax为最大值的别名 ,age是要求最大值的列
AggregationBuilder builder = AggregationBuilders.max("aggMax").field("age");
SearchResponse response = client.prepareSearch("lib3").addAggregation(builder).get();
Max max = response.getAggregations().get("aggMax");
//打印最大值
System.out.println(max.getValue());
}

2、min:最小值

//min 求最小值
@Test
public void test31() throws UnknownHostException{
//1、指定es集群 cluster.name 是固定的key值,my-application是ES集群的名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
//2.创建访问ES服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
//aggMin为最小值的别名 ,age是要求最小值的列
AggregationBuilder builder = AggregationBuilders.min("aggMin").field("age");
SearchResponse response = client.prepareSearch("lib3").addAggregation(builder).get();
Min min = response.getAggregations().get("aggMin");
//打印最小值
System.out.println(min.getValue());
}

3、avg:平均值

//avg 求平均值
@Test
public void test32() throws UnknownHostException{
//1、指定es集群 cluster.name 是固定的key值,my-application是ES集群的名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
//2.创建访问ES服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
//aggavg为平均值的别名 ,age是要求最大值的列
AggregationBuilder builder = AggregationBuilders.avg("aggavg").field("age");
SearchResponse response = client.prepareSearch("lib3").addAggregation(builder).get();
Avg avg = response.getAggregations().get("aggavg");
//打印平均值
System.out.println(avg.getValue());
}

4、sum:求和

//sum 求和
@Test
public void test33() throws UnknownHostException{
//1、指定es集群 cluster.name 是固定的key值,my-application是ES集群的名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
//2.创建访问ES服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
//aggSum为总和的别名 ,age是要求总和的列
AggregationBuilder builder = AggregationBuilders.max("aggSum").field("age");
SearchResponse response = client.prepareSearch("lib3").addAggregation(builder).get();
Sum sum = response.getAggregations().get("aggSum");
//打印总和
System.out.println(sum.getValue());
}

5、cardinality:求基数

  说明:基数就是互不相同的个数,具体看代码及注释

//cardinality基数(互不相同的个数)
@Test
public void test34() throws UnknownHostException{
//1、指定es集群 cluster.name 是固定的key值,my-application是ES集群的名称
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
//2.创建访问ES服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
//Cardinality基数查询: 查询age字段中互不相同的个数
AggregationBuilder builder = AggregationBuilders.cardinality("aggCardinality").field("age");
SearchResponse response = client.prepareSearch("lib3").addAggregation(builder).get();
Cardinality cardinality = response.getAggregations().get("aggCardinality");
//打印基数
System.out.println(cardinality.getValue());
}

下一篇博客本人将书写java操作elasticsearch实现query String。对后期博客感兴趣的朋友可以关注交流,转发请说明出处,本人的博客地址为:https://www.cnblogs.com/chenyuanbo/

技术在于交流!