java操作elasticsearch实现聚合查询

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/

技术在于交流！