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 ofDeferringBucketCollector
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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classDeferringBucketCollector
-
needsScores
public boolean needsScores()
-
preCollection
public void preCollection() throws java.io.IOException
Description copied from class:BucketCollector
Pre collection callback.- Specified by:
preCollection
in classBucketCollector
- Throws:
java.io.IOException
-
getLeafCollector
public LeafBucketCollector getLeafCollector(org.apache.lucene.index.LeafReaderContext ctx) throws java.io.IOException
- Specified by:
getLeafCollector
in interfaceorg.apache.lucene.search.Collector
- Specified by:
getLeafCollector
in classBucketCollector
- 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 classBucketCollector
-
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 classDeferringBucketCollector
- 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 classDeferringBucketCollector
-
-