//聚合查询

@Test

public void test15() throws IOException, InterruptedException, ExecutionException {

//指定ES集群

Settings settings = Settings.builder().put("cluster.name","haijines").build();

//创建访问es服务器的客户端

TransportClient client = new PreBuiltTransportClient(settings)

.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.159"),9300));

//最大

// AggregationBuilder agg = AggregationBuilders.max("aggMax").field("age");

//

// SearchResponse response = client.prepareSearch("lib3").addAggregation(agg).get();

// Max max = response.getAggregations().get("aggMax");

//

// System.out.println(max.getValue());

//

//最小

// AggregationBuilder agg = AggregationBuilders.min("aggMin").field("age");

//

// SearchResponse response = client.prepareSearch("lib3").addAggregation(agg).get();

// Min min = response.getAggregations().get("aggMin");

//

// System.out.println(min.getValue());

//

//平均

// AggregationBuilder agg = AggregationBuilders.avg("aggAvg").field("age");

//

// SearchResponse response = client.prepareSearch("lib3").addAggregation(agg).get();

// Avg avg = response.getAggregations().get("aggAvg");

//

// System.out.println(avg.getValue());

//

//和

// AggregationBuilder agg = AggregationBuilders.sum("aggSum").field("age");

//

// SearchResponse response = client.prepareSearch("lib3").addAggregation(agg).get();

// Sum sum = response.getAggregations().get("aggSum");

//

// System.out.println(sum.getValue());

//

//奇数 互不相同

AggregationBuilder agg = AggregationBuilders.cardinality("aggCardinality").field("age");

SearchResponse response = client.prepareSearch("lib3").addAggregation(agg).get();

Cardinality cardinality = response.getAggregations().get("aggCardinality");

System.out.println(cardinality.getValue());

}