Package org.elasticsearch.search.aggregations

Class InternalAggregation.ReduceContext

java.lang.Object
org.elasticsearch.search.aggregations.InternalAggregation.ReduceContext
Enclosing class:
InternalAggregation
public static class InternalAggregation.ReduceContext
extends java.lang.Object

  • Constructor Summary

    Constructors 
    Constructor Description
    ReduceContext​(BigArrays bigArrays, ScriptService scriptService, boolean isFinalReduce)  
    ReduceContext​(BigArrays bigArrays, ScriptService scriptService, java.util.function.IntConsumer multiBucketConsumer, boolean isFinalReduce)  

  • Method Summary

    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()  

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • isFinalReduce

      public boolean isFinalReduce()
      Returns 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 losing information can only be applied during the final reduce phase.

    • bigArrays

      public BigArrays bigArrays()

    • scriptService

      public ScriptService scriptService()

    • consumeBucketsAndMaybeBreak

      public 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