Class MultiBucketConsumerService
- java.lang.Object
-
- org.elasticsearch.search.aggregations.MultiBucketConsumerService
-
public class MultiBucketConsumerService extends java.lang.Object
An aggregation service that creates instances ofMultiBucketConsumerService.MultiBucketConsumer
. The consumer is used byBucketsAggregator
andInternalMultiBucketAggregation
to limit the number of buckets created inAggregator.buildAggregation(long)
andInternalAggregation.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
AnIntConsumer
that throws aMultiBucketConsumerService.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MultiBucketConsumerService.MultiBucketConsumer
create()
-
-
-
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()
-
-