Package org.elasticsearch.search.aggregations

Class MultiBucketConsumerService

java.lang.Object

org.elasticsearch.search.aggregations.MultiBucketConsumerService

public class MultiBucketConsumerService
extends java.lang.Object

An aggregation service that creates instances of MultiBucketConsumerService.MultiBucketConsumer. The consumer is used by BucketsAggregator and InternalMultiBucketAggregation to limit the number of buckets created in Aggregator.buildAggregation(long) and InternalAggregation.reduce(java.util.List<org.elasticsearch.search.aggregations.InternalAggregation>, org.elasticsearch.search.aggregations.InternalAggregation.ReduceContext). The limit can be set by changing the `search.max_buckets` cluster setting and defaults to 10000.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiBucketConsumerService.MultiBucketConsumer	An IntConsumer that throws a MultiBucketConsumerService.TooManyBucketsException when the sum of the provided values is above the limit (`search.max_buckets`).
static class	MultiBucketConsumerService.TooManyBucketsException

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_LIMIT_MAX_BUCKETS
static Setting<java.lang.Integer>	MAX_BUCKET_SETTING
static int	SOFT_LIMIT_MAX_BUCKETS

Constructor Summary

Constructors

Constructor	Description
MultiBucketConsumerService(ClusterService clusterService, Settings settings)

Method Summary

Modifier and Type	Method	Description
MultiBucketConsumerService.MultiBucketConsumer	create()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LIMIT_MAX_BUCKETS

public static final int DEFAULT_LIMIT_MAX_BUCKETS

See Also:

Constant Field Values

SOFT_LIMIT_MAX_BUCKETS

public static final int SOFT_LIMIT_MAX_BUCKETS

See Also:

Constant Field Values

MAX_BUCKET_SETTING

public static final Setting<java.lang.Integer> MAX_BUCKET_SETTING

Constructor Detail

MultiBucketConsumerService

public MultiBucketConsumerService(ClusterService clusterService,
                                  Settings settings)

Method Detail

create

public MultiBucketConsumerService.MultiBucketConsumer create()