Package org.elasticsearch.search.aggregations

Class DelayedBucket<B extends InternalMultiBucketAggregation.InternalBucket>

java.lang.Object

org.elasticsearch.search.aggregations.DelayedBucket<B>

public final class DelayedBucket<B extends InternalMultiBucketAggregation.InternalBucket>
extends Object

A wrapper around reducing buckets with the same key that can delay that reduction as long as possible. It's stateful and not even close to thread safe.

Constructor Summary

Constructors

Constructor	Description
DelayedBucket(BiFunction<List<B>,InternalAggregation.ReduceContext,B> reduce, InternalAggregation.ReduceContext reduceContext, List<B> toReduce)	Build a delayed bucket.

Method Summary

Modifier and Type	Method	Description
long	getDocCount()	Count the documents in the buckets.
B	reduced()	The reduced bucket.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DelayedBucket

public DelayedBucket(BiFunction<List<B>,InternalAggregation.ReduceContext,B> reduce,
 InternalAggregation.ReduceContext reduceContext,
 List<B> toReduce)

Build a delayed bucket.

We take a BiFunction to match the signature of InternalMultiBucketAggregation.reduceBucket(java.util.List<B>, org.elasticsearch.search.aggregations.InternalAggregation.ReduceContext).

Method Details

reduced

public B reduced()

The reduced bucket. If the bucket hasn't been reduced already this will reduce the sub-aggs and throw out the list to reduce.

getDocCount

public long getDocCount()

Count the documents in the buckets.

toString

public String toString()

Overrides:

toString in class Object