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

Class MapStringTermsAggregator.ValuesSourceCollectorSource

java.lang.Object

org.elasticsearch.search.aggregations.bucket.terms.MapStringTermsAggregator.ValuesSourceCollectorSource

All Implemented Interfaces:

Closeable, AutoCloseable, Releasable, MapStringTermsAggregator.CollectorSource

Enclosing class:

MapStringTermsAggregator

public static class MapStringTermsAggregator.ValuesSourceCollectorSource
extends Object
implements MapStringTermsAggregator.CollectorSource

Fetch values from a ValuesSource.

Constructor Summary

Constructors

Constructor	Description
ValuesSourceCollectorSource(ValuesSourceConfig valuesSourceConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
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 class java.lang.Object

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

Constructor Details

ValuesSourceCollectorSource

public ValuesSourceCollectorSource(ValuesSourceConfig valuesSourceConfig)

Method Details

describe

public String describe()

Description copied from interface: MapStringTermsAggregator.CollectorSource

A description of the strategy to include in profile results.

Specified by:

describe in interface MapStringTermsAggregator.CollectorSource

collectDebugInfo

public void collectDebugInfo(BiConsumer<String,Object> add)

Description copied from interface: MapStringTermsAggregator.CollectorSource

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

Specified by:

collectDebugInfo in interface MapStringTermsAggregator.CollectorSource

needsScores

public boolean needsScores()

Description copied from interface: MapStringTermsAggregator.CollectorSource

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

Specified by:

needsScores in interface MapStringTermsAggregator.CollectorSource

getLeafCollector

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

Description copied from interface: MapStringTermsAggregator.CollectorSource

Build the collector.

Specified by:

getLeafCollector in interface MapStringTermsAggregator.CollectorSource

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Releasable