Package org.elasticsearch.search.aggregations.bucket.terms

Interface MapStringTermsAggregator.CollectorSource

All Superinterfaces:

AutoCloseable, Closeable, org.elasticsearch.core.Releasable

All Known Implementing Classes:

MapStringTermsAggregator.ValuesSourceCollectorSource

Enclosing class:

MapStringTermsAggregator

public static interface MapStringTermsAggregator.CollectorSource
extends org.elasticsearch.core.Releasable

Abstraction on top of building collectors to fetch values so terms, significant_terms, and significant_text can share a bunch of aggregation code.

Method Summary

Modifier and Type	Method	Description
void	collectDebugInfo(BiConsumer<String,Object> add)	Collect debug information to add to the profiling results.
String	describe()	A description of the strategy to include in profile results.
LeafBucketCollector	getLeafCollector(IncludeExclude.StringFilter includeExclude, org.apache.lucene.index.LeafReaderContext ctx, LeafBucketCollector sub, LongConsumer addRequestCircuitBreakerBytes, MapStringTermsAggregator.CollectConsumer consumer)	Build the collector.
boolean	needsScores()	Does this MapStringTermsAggregator.CollectorSource need queries to calculate the score?

Methods inherited from interface org.elasticsearch.core.Releasable

close

Method Details

describe

String describe()

A description of the strategy to include in profile results.

collectDebugInfo

void collectDebugInfo(BiConsumer<String,Object> add)

Collect debug information to add to the profiling results. This will only be called if the aggregation is being profiled.

needsScores

boolean needsScores()

Does this MapStringTermsAggregator.CollectorSource need queries to calculate the score?

getLeafCollector

LeafBucketCollector getLeafCollector(IncludeExclude.StringFilter includeExclude,
 org.apache.lucene.index.LeafReaderContext ctx,
 LeafBucketCollector sub,
 LongConsumer addRequestCircuitBreakerBytes,
 MapStringTermsAggregator.CollectConsumer consumer)
                              throws IOException

Build the collector.

Throws:

IOException