public static class InternalAggregation.ReduceContext
extends java.lang.Object
Constructor | Description |
---|---|
ReduceContext(BigArrays bigArrays,
ScriptService scriptService,
boolean isFinalReduce) |
|
ReduceContext(BigArrays bigArrays,
ScriptService scriptService,
java.util.function.IntConsumer multiBucketConsumer,
boolean isFinalReduce) |
Modifier and Type | Method | Description |
---|---|---|
BigArrays |
bigArrays() |
|
void |
consumeBucketsAndMaybeBreak(int size) |
Adds count buckets to the global count for the request and fails if this number is greater than
the maximum number of buckets allowed in a response
|
boolean |
isFinalReduce() |
Returns
true iff the current reduce phase is the final reduce phase. |
ScriptService |
scriptService() |
public ReduceContext(BigArrays bigArrays, ScriptService scriptService, boolean isFinalReduce)
public ReduceContext(BigArrays bigArrays, ScriptService scriptService, java.util.function.IntConsumer multiBucketConsumer, boolean isFinalReduce)
public boolean isFinalReduce()
true
iff the current reduce phase is the final reduce phase. This indicates if operations like
pipeline aggregations should be applied or if specific features like minDocCount should be taken into account.
Operations that are potentially loosing information can only be applied during the final reduce phase.public BigArrays bigArrays()
public ScriptService scriptService()
public void consumeBucketsAndMaybeBreak(int size)