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

Class MapStringTermsAggregator.ValuesSourceCollectorSource

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.elasticsearch.common.lease.Releasable, MapStringTermsAggregator.CollectorSource

Enclosing class:

MapStringTermsAggregator

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

Fetch values from a ValuesSource.

Constructor Summary

Constructors

Constructor	Description
ValuesSourceCollectorSource(ValuesSource valuesSource)

Method Summary

Modifier and Type	Method	Description
void	close()
LeafBucketCollector	getLeafCollector(IncludeExclude.StringFilter includeExclude, org.apache.lucene.index.LeafReaderContext ctx, LeafBucketCollector sub, java.util.function.LongConsumer addRequestCircuitBreakerBytes, MapStringTermsAggregator.CollectConsumer consumer)
boolean	needsScores()

Methods inherited from class java.lang.Object

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

Constructor Details

ValuesSourceCollectorSource

public ValuesSourceCollectorSource(ValuesSource valuesSource)

Method Details

needsScores

public boolean needsScores()

Specified by:

needsScores in interface MapStringTermsAggregator.CollectorSource

getLeafCollector

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

Specified by:

getLeafCollector in interface MapStringTermsAggregator.CollectorSource

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface org.elasticsearch.common.lease.Releasable