org.elasticsearch.search.aggregations.bucket

Class DeferableBucketAggregator

java.lang.Object

org.elasticsearch.search.aggregations.BucketCollector

org.elasticsearch.search.aggregations.Aggregator

org.elasticsearch.search.aggregations.AggregatorBase

org.elasticsearch.search.aggregations.bucket.BucketsAggregator

org.elasticsearch.search.aggregations.bucket.DeferableBucketAggregator

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.lucene.search.Collector, Releasable

Direct Known Subclasses:

SamplerAggregator, TermsAggregator

public abstract class DeferableBucketAggregator
extends BucketsAggregator

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.Aggregator

Aggregator.Parser, Aggregator.SubAggCollectionMode

Field Summary

Fields inherited from class org.elasticsearch.search.aggregations.AggregatorBase

collectableSubAggregators, context, DEFAULT_WEIGHT, name, parent, subAggregators

Fields inherited from class org.elasticsearch.search.aggregations.BucketCollector

NO_OP_COLLECTOR

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DeferableBucketAggregator(java.lang.String name, AggregatorFactories factories, SearchContext context, Aggregator parent, java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metaData)

Method Summary

Modifier and Type	Method and Description
protected void	doPreCollection() Can be overridden by aggregator implementation to be called back when the collection phase starts.
DeferringBucketCollector	getDeferringCollector()
protected void	runDeferredCollections(long... bucketOrds)
protected boolean	shouldDefer(Aggregator aggregator) This method should be overridden by subclasses that want to defer calculation of a child aggregation until a first pass is complete and a set of buckets has been pruned.

Methods inherited from class org.elasticsearch.search.aggregations.bucket.BucketsAggregator

bucketAggregations, bucketDocCount, bucketEmptyAggregations, close, collectBucket, collectExistingBucket, getDocCounts, grow, incrementBucketDocCount, maxBucketOrd

Methods inherited from class org.elasticsearch.search.aggregations.AggregatorBase

addRequestCircuitBreakerBytes, buildEmptySubAggregations, context, doClose, doPostCollection, getLeafCollector, getLeafCollector, metaData, name, needsScores, parent, pipelineAggregators, postCollection, preCollection, preGetSubLeafCollectors, subAggregator, subAggregators, toString

Methods inherited from class org.elasticsearch.search.aggregations.Aggregator

buildAggregation, buildEmptyAggregation, descendsFromBucketAggregator

Methods inherited from class org.elasticsearch.search.aggregations.BucketCollector

wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

DeferableBucketAggregator

protected DeferableBucketAggregator(java.lang.String name,
                                    AggregatorFactories factories,
                                    SearchContext context,
                                    Aggregator parent,
                                    java.util.List<PipelineAggregator> pipelineAggregators,
                                    java.util.Map<java.lang.String,java.lang.Object> metaData)
                             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

doPreCollection

protected void doPreCollection()
                        throws java.io.IOException

Description copied from class: AggregatorBase

Can be overridden by aggregator implementation to be called back when the collection phase starts.

Overrides:

doPreCollection in class AggregatorBase

Throws:

java.io.IOException

getDeferringCollector

public DeferringBucketCollector getDeferringCollector()

shouldDefer

protected boolean shouldDefer(Aggregator aggregator)

This method should be overridden by subclasses that want to defer calculation of a child aggregation until a first pass is complete and a set of buckets has been pruned. Deferring collection will require the recording of all doc/bucketIds from the first pass and then the sub class should call runDeferredCollections(long...) for the selected set of buckets that survive the pruning.

Parameters:

aggregator - the child aggregator

Returns:

true if the aggregator should be deferred until a first pass at collection has completed

runDeferredCollections

protected final void runDeferredCollections(long... bucketOrds)
                                     throws java.io.IOException

Throws:

java.io.IOException