Package org.elasticsearch.search.aggregations.bucket.sampler

Class BestDocsDeferringCollector

java.lang.Object

org.elasticsearch.search.aggregations.BucketCollector

org.elasticsearch.search.aggregations.bucket.DeferringBucketCollector

org.elasticsearch.search.aggregations.bucket.sampler.BestDocsDeferringCollector

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.search.Collector, org.elasticsearch.core.Releasable

public class BestDocsDeferringCollector
extends DeferringBucketCollector
implements org.elasticsearch.core.Releasable

A specialization of DeferringBucketCollector that collects all matches and then replays only the top scoring documents to child aggregations. The method createTopDocsCollector(int) is designed to be overridden and allows subclasses to choose a custom collector implementation for determining the top N matches.

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

Method Summary

Modifier and Type	Method	Description
void	close()
protected org.apache.lucene.search.TopDocsCollector<? extends org.apache.lucene.search.ScoreDoc>	createTopDocsCollector(int size)
int	getDocCount(long parentBucket)
LeafBucketCollector	getLeafCollector(org.apache.lucene.index.LeafReaderContext ctx)
protected long	getPriorityQueueSlotSize()
void	postCollection()	Post-collection callback.
void	preCollection()	Pre collection callback.
void	prepareSelectedBuckets(long... selectedBuckets)	Replay the deferred hits on the selected buckets.
org.apache.lucene.search.ScoreMode	scoreMode()
void	setDeferredCollector(Iterable<BucketCollector> deferredCollectors)	Set the deferred collectors.

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

wrap

Methods inherited from class java.lang.Object

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

Method Details

scoreMode

public org.apache.lucene.search.ScoreMode scoreMode()

Specified by:

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

setDeferredCollector

public void setDeferredCollector(Iterable<BucketCollector> deferredCollectors)

Set the deferred collectors.

Specified by:

setDeferredCollector in class DeferringBucketCollector

getLeafCollector

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

Specified by:

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

Specified by:

getLeafCollector in class BucketCollector

Throws:

IOException

createTopDocsCollector

protected org.apache.lucene.search.TopDocsCollector<? extends org.apache.lucene.search.ScoreDoc> createTopDocsCollector(int size)
                                                                                                                 throws IOException

Throws:

IOException

getPriorityQueueSlotSize

protected long getPriorityQueueSlotSize()

preCollection

public void preCollection()
                   throws IOException

Description copied from class: BucketCollector

Pre collection callback.

Specified by:

preCollection in class BucketCollector

Throws:

IOException

postCollection

public void postCollection()
                    throws IOException

Description copied from class: BucketCollector

Post-collection callback.

Specified by:

postCollection in class BucketCollector

Throws:

IOException

prepareSelectedBuckets

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

Description copied from class: DeferringBucketCollector

Replay the deferred hits on the selected buckets.

Specified by:

prepareSelectedBuckets in class DeferringBucketCollector

Throws:

IOException

getDocCount

public int getDocCount(long parentBucket)

close

public void close()
           throws ElasticsearchException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable

Throws:

ElasticsearchException