org.elasticsearch.search.aggregations

Class FilteringBucketCollector

java.lang.Object

org.elasticsearch.search.aggregations.BucketCollector

org.elasticsearch.search.aggregations.FilteringBucketCollector

All Implemented Interfaces:

AutoCloseable, Releasable, ReaderContextAware

public class FilteringBucketCollector
extends BucketCollector
implements Releasable

Filters a collection stream of docIds and related buckets using a sorted list of valid bucket ordinals.

Nested Class Summary

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

BucketCollector.BucketAnalysisCollector

Field Summary

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

NO_OP_COLLECTOR

Constructor Summary

Constructors

Constructor and Description
FilteringBucketCollector(long[] validBucketOrds, BucketCollector delegate, BigArrays bigArrays)

Method Summary

Modifier and Type	Method and Description
void	close()
void	collect(int docId, long bucketOrdinal) Called during the query phase, to collect & aggregate the given document.
void	gatherAnalysis(BucketCollector.BucketAnalysisCollector analysisCollector, long bucketOrdinal) Called post-collection to gather the results from surviving buckets.
void	postCollection() Post collection callback.
void	setNextReader(org.apache.lucene.index.AtomicReaderContext reader)

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

wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

FilteringBucketCollector

public FilteringBucketCollector(long[] validBucketOrds,
                                BucketCollector delegate,
                                BigArrays bigArrays)

Parameters:

the - valid BucketOrds

delegate - The collector that will be called for any buckets listed in sortedBucketOrds

Method Detail

setNextReader

public final void setNextReader(org.apache.lucene.index.AtomicReaderContext reader)

Specified by:

setNextReader in interface ReaderContextAware

collect

public final void collect(int docId,
                          long bucketOrdinal)
                   throws IOException

Description copied from class: BucketCollector

Called during the query phase, to collect & aggregate the given document.

Specified by:

collect in class BucketCollector

bucketOrdinal - The ordinal of the bucket this aggregator belongs to, assuming this aggregator is not a top level aggregator. Typically, aggregators with #bucketAggregationMode set to Aggregator.BucketAggregationMode.MULTI_BUCKETS will heavily depend on this ordinal. Other aggregators may or may not use it and can see this ordinal as just an extra information for the aggregation context. For top level aggregators, the ordinal will always be equal to 0.

Throws:

IOException

postCollection

public final void postCollection()
                          throws IOException

Description copied from class: BucketCollector

Post collection callback.

Specified by:

postCollection in class BucketCollector

Throws:

IOException

close

public void close()
           throws ElasticsearchException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Releasable

Throws:

ElasticsearchException

gatherAnalysis

public void gatherAnalysis(BucketCollector.BucketAnalysisCollector analysisCollector,
                           long bucketOrdinal)

Description copied from class: BucketCollector

Called post-collection to gather the results from surviving buckets.

Specified by:

gatherAnalysis in class BucketCollector