import org.elasticsearch.search.aggregations.bucket.range.RangeBuilder; //导入依赖的package包/类
public SimpleAggregationBuilder<SimpleSearchQueryBuilder> aggRanges(String name, String field, List<RangeQueryer> ranges) {
	RangeBuilder rangeBuilder = AggregationBuilders.range(name);
	ranges.stream().forEach(r->{
		if(!r.isValid()){
			return ;
		}
		if(r.getFrom()==null){
			rangeBuilder.addUnboundedTo(r.getKey(), r.getTo());
		}else if(r.getTo()==null){
			rangeBuilder.addUnboundedFrom(r.getKey(), r.getFrom());
		}else{
			rangeBuilder.addRange(r.getKey(), r.getFrom(), r.getTo());
		}
	});
	return agg(rangeBuilder).field(field);
}
 

import org.elasticsearch.search.aggregations.bucket.range.RangeBuilder; //导入依赖的package包/类
@Override
public List<AggregationBuilder> buildFacets() {
    RangeBuilder rangeFacetBuilder = AggregationBuilders.range(getEsFieldName()).field(getEsFieldName()).addUnboundedFrom(this.ranges[0]);
    int i = 1;
    for (; i < this.ranges.length - 2; i += 2) {
        rangeFacetBuilder.addRange(this.ranges[i], this.ranges[i + 1]);
    }
    rangeFacetBuilder.addUnboundedTo(this.ranges[i]);
    return Collections.singletonList(rangeFacetBuilder);
}
 

import org.elasticsearch.search.aggregations.bucket.range.RangeBuilder; //导入依赖的package包/类
/**
 * Create a new {@link Range} aggregation with the given name.
 */
public static RangeBuilder range(String name) {
    return new RangeBuilder(name);
}
 

import org.elasticsearch.search.aggregations.bucket.range.RangeBuilder; //导入依赖的package包/类
/**
 * 构建范围查询
 * 
 * @param field
 * @return
 */
private RangeBuilder rangeBuilder(MethodField field) {

	LinkedList<KVValue> params = new LinkedList<>(field.getParams());

	String fieldName = params.poll().toString();

	double[] ds = Util.KV2DoubleArr(params);

	RangeBuilder range = AggregationBuilders.range(field.getAlias()).field(fieldName);

	for (int i = 1; i < ds.length; i++) {
		range.addRange(ds[i - 1], ds[i]);
	}

	return range;
}
 

import org.elasticsearch.search.aggregations.bucket.range.RangeBuilder; //导入依赖的package包/类
@Test
public void assertMultipleMetricAggregationWithParentRangeAggregation() {
    String indexName = "test1";
    int size = 1;

    Map<String, Integer> termsFactor = new HashMap<String, Integer>();
    termsFactor.put("foo", 1);
    termsFactor.put("bar", 1);

    buildTestDataset(1, indexName, "type1", size, termsFactor);

    RangeBuilder rangeBuilder = new RangeBuilder("ranges")
            .addRange(0, 100).addRange(100, 200).addRange(200, 300).addRange(300, 400).addRange(400, 500)
            .field("value2")
            .subAggregation(new MultipleMetricBuilder("metrics")
                    .script(new ScriptBuilder("ratio").script(new Script("value1 / value1c")))
                    .field(new SumBuilder("value1")
                            .field("value1")
                    )
                    .field(new CountBuilder("value1c")
                            .field("value1")
                    )
            );

    DateHistogramBuilder dateHistogramBuilder = new DateHistogramBuilder("dates")
            .interval(DateHistogramInterval.DAY)
            .field("date")
            .subAggregation(rangeBuilder);


    SearchResponse searchResponse = client().prepareSearch(indexName)
            .setQuery(matchAllQuery()) //termQuery("field0", "foo")
            .addAggregation(dateHistogramBuilder)
            .execute().actionGet();

    Histogram dates = searchResponse.getAggregations().get("dates");
    for (Histogram.Bucket date: dates.getBuckets() ) {
        Range buckets = date.getAggregations().get("ranges");

        for (Range.Bucket bucket : buckets.getBuckets()) {
            MultipleMetric metrics = bucket.getAggregations().get("metrics");
            if (bucket.getFromAsString().equals("0.0") && bucket.getToAsString().equals("100.0")) {
                assertEquals(90.0, metrics.getValue("value1"), 0.0);
                assertEquals(20.0, metrics.getValue("value1c"), 0.0);
            } else {
                assertEquals(0.0, metrics.getValue("value1"), 0.0);
                assertEquals(0.0, metrics.getValue("value1c"), 0.0);
            }

        }
    }
}