org.elasticsearch.search.aggregations.bucket.sampler

Class DiversifiedBytesHashSamplerAggregator

java.lang.Object

org.elasticsearch.search.aggregations.BucketCollector

org.elasticsearch.search.aggregations.Aggregator

org.elasticsearch.search.aggregations.AggregatorBase

org.elasticsearch.search.aggregations.bucket.BucketsAggregator

org.elasticsearch.search.aggregations.bucket.SingleBucketAggregator

org.elasticsearch.search.aggregations.bucket.sampler.SamplerAggregator

org.elasticsearch.search.aggregations.bucket.sampler.DiversifiedBytesHashSamplerAggregator

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.lucene.search.Collector, Releasable

public class DiversifiedBytesHashSamplerAggregator
extends SamplerAggregator

Alternative, faster implementation for converting String keys to longs but with the potential for hash collisions.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.search.aggregations.bucket.sampler.SamplerAggregator

SamplerAggregator.ExecutionMode

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

Aggregator.Parser, Aggregator.SubAggCollectionMode

Field Summary

Fields inherited from class org.elasticsearch.search.aggregations.bucket.sampler.SamplerAggregator

bdd, EXECUTION_HINT_FIELD, MAX_DOCS_PER_VALUE_FIELD, SHARD_SIZE_FIELD, shardSize

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

collectableSubAggregators, context, DEFAULT_WEIGHT, name, parent, subAggregators

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

NO_OP_COLLECTOR

Constructor Summary

Constructors

Constructor and Description
DiversifiedBytesHashSamplerAggregator(java.lang.String name, int shardSize, AggregatorFactories factories, SearchContext context, Aggregator parent, java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metaData, ValuesSource valuesSource, int maxDocsPerValue)

Method Summary

Modifier and Type	Method and Description
DeferringBucketCollector	getDeferringCollector()

Methods inherited from class org.elasticsearch.search.aggregations.bucket.sampler.SamplerAggregator

buildAggregation, buildEmptyAggregation, doClose, getLeafCollector, needsScores, shouldDefer

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

bucketAggregations, bucketDocCount, bucketEmptyAggregations, close, collectBucket, collectExistingBucket, getDocCounts, grow, incrementBucketDocCount, maxBucketOrd

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

buildEmptySubAggregations, context, doPostCollection, doPreCollection, getLeafCollector, metaData, name, parent, pipelineAggregators, postCollection, preCollection, runDeferredCollections, subAggregator, subAggregators, toString

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

descendsFromBucketAggregator

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

wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

DiversifiedBytesHashSamplerAggregator

public DiversifiedBytesHashSamplerAggregator(java.lang.String name,
                                             int shardSize,
                                             AggregatorFactories factories,
                                             SearchContext context,
                                             Aggregator parent,
                                             java.util.List<PipelineAggregator> pipelineAggregators,
                                             java.util.Map<java.lang.String,java.lang.Object> metaData,
                                             ValuesSource valuesSource,
                                             int maxDocsPerValue)
                                      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getDeferringCollector

public DeferringBucketCollector getDeferringCollector()

Overrides:

getDeferringCollector in class SamplerAggregator