zoukankan      html  css  js  c++  java
  • 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/

    技术在于交流!

  • 相关阅读:
    ZooKeeper实现配置中心的实例(原生API实现)(转)
    com.101tec.ZKClient实现中的subscribeDataChanges设置的监听器事件不回调的问题研究
    Spring Framework体系结构简介
    Spring MVC中@RequestMapping注解使用技巧(转)
    Tomcat配置文件server.xml(转)
    Ubuntu 16.04配置VNC进行远程桌面连接
    Eclipse查看方法/类调用的方法
    MySQL Workbench查看和修改表字段的Comment值
    MySQL常用函数(转)
    MySQL大小写问题的简单说明(关键字/函数/表名)(转)
  • 原文地址:https://www.cnblogs.com/chenyuanbo/p/10296848.html
Copyright © 2011-2022 走看看