Package org.elasticsearch.search.aggregations.bucket

Class MergingBucketsDeferringCollector

java.lang.Object

org.elasticsearch.search.aggregations.BucketCollector

org.elasticsearch.search.aggregations.bucket.DeferringBucketCollector

org.elasticsearch.search.aggregations.bucket.MergingBucketsDeferringCollector

All Implemented Interfaces:

org.apache.lucene.search.Collector

public class MergingBucketsDeferringCollector
extends DeferringBucketCollector

A specialization of DeferringBucketCollector that collects all matches and then is able to replay a given subset of buckets. Exposes mergeBuckets, which can be invoked by the aggregator when increasing the rounding interval.

Nested Class Summary

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

DeferringBucketCollector.WrappedAggregator

Field Summary

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

NO_OP_COLLECTOR

Constructor Summary

Constructors

Constructor	Description
MergingBucketsDeferringCollector(SearchContext context)

Method Summary

Modifier and Type	Method	Description
LeafBucketCollector	getLeafCollector(org.apache.lucene.index.LeafReaderContext ctx)
void	mergeBuckets(long[] mergeMap)
boolean	needsScores()
void	postCollection()	Post-collection callback.
void	preCollection()	Pre collection callback.
void	prepareSelectedBuckets(long... selectedBuckets)	Replay the wrapped collector, but only on a selection of buckets.
void	setDeferredCollector(java.lang.Iterable<BucketCollector> deferredCollectors)	Set the deferred collectors.
Aggregator	wrap(Aggregator in)	Wrap the provided aggregator so that it behaves (almost) as if it had been collected directly.

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

replay

Methods inherited from class java.lang.Object

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

Constructor Detail

MergingBucketsDeferringCollector

public MergingBucketsDeferringCollector(SearchContext context)

Method Detail

setDeferredCollector

public void setDeferredCollector(java.lang.Iterable<BucketCollector> deferredCollectors)

Description copied from class: DeferringBucketCollector

Set the deferred collectors.

Specified by:

setDeferredCollector in class DeferringBucketCollector

needsScores

public boolean needsScores()

preCollection

public void preCollection()
                   throws java.io.IOException

Description copied from class: BucketCollector

Pre collection callback.

Specified by:

preCollection in class BucketCollector

Throws:

java.io.IOException

getLeafCollector

public LeafBucketCollector getLeafCollector(org.apache.lucene.index.LeafReaderContext ctx)
                                     throws java.io.IOException

Specified by:

getLeafCollector in interface org.apache.lucene.search.Collector

Specified by:

getLeafCollector in class BucketCollector

Throws:

java.io.IOException

mergeBuckets

public void mergeBuckets(long[] mergeMap)

postCollection

public void postCollection()

Description copied from class: BucketCollector

Post-collection callback.

Specified by:

postCollection in class BucketCollector

prepareSelectedBuckets

public void prepareSelectedBuckets(long... selectedBuckets)
                            throws java.io.IOException

Replay the wrapped collector, but only on a selection of buckets.

Specified by:

prepareSelectedBuckets in class DeferringBucketCollector

Throws:

java.io.IOException

wrap

public Aggregator wrap(Aggregator in)

Wrap the provided aggregator so that it behaves (almost) as if it had been collected directly.

Overrides:

wrap in class DeferringBucketCollector