Package org.apache.druid.query.groupby

Class GroupByQueryConfig

java.lang.Object
org.apache.druid.query.groupby.GroupByQueryConfig
public class GroupByQueryConfig extends Object

  • Field Details

  • Constructor Details

    • GroupByQueryConfig

      public GroupByQueryConfig()

  • Method Details

    • isSingleThreaded

      public boolean isSingleThreaded()

    • setSingleThreaded

      public void setSingleThreaded(boolean singleThreaded)

    • getBufferGrouperMaxSize

      public int getBufferGrouperMaxSize()

    • getBufferGrouperMaxLoadFactor

      public float getBufferGrouperMaxLoadFactor()

    • getBufferGrouperInitialBuckets

      public int getBufferGrouperInitialBuckets()

    • getActualMaxSelectorDictionarySize

      public long getActualMaxSelectorDictionarySize(DruidProcessingConfig processingConfig)

    • getActualMaxMergingDictionarySize

      public long getActualMaxMergingDictionarySize(long maxHeapSize, int numConcurrentQueries)
      For unit tests. Production code should use getActualMaxMergingDictionarySize(long, int).

    • getActualMaxMergingDictionarySize

      public long getActualMaxMergingDictionarySize(DruidProcessingConfig processingConfig)

    • getMaxOnDiskStorage

      public HumanReadableBytes getMaxOnDiskStorage()

    • getDefaultOnDiskStorage

      public HumanReadableBytes getDefaultOnDiskStorage()
      Mirror maxOnDiskStorage if defaultOnDiskStorage's default is not overridden by cluster operator. This mirroring is done to maintain continuity in behavior between Druid versions. If an operator wants to use defaultOnDiskStorage, they have to explicitly override it.
      Returns:
      The working value for defaultOnDiskStorage

    • isForcePushDownLimit

      public boolean isForcePushDownLimit()

    • isApplyLimitPushDownToSegment

      public boolean isApplyLimitPushDownToSegment()

    • isForceHashAggregation

      public boolean isForceHashAggregation()

    • getIntermediateCombineDegree

      public int getIntermediateCombineDegree()

    • getNumParallelCombineThreads

      public int getNumParallelCombineThreads()

    • isMergeThreadLocal

      public boolean isMergeThreadLocal()

    • getDeferExpressionDimensions

      public DeferExpressionDimensions getDeferExpressionDimensions()

    • isVectorize

      public boolean isVectorize()

    • isIntermediateResultAsMapCompat

      public boolean isIntermediateResultAsMapCompat()

    • isForcePushDownNestedQuery

      public boolean isForcePushDownNestedQuery()

    • isMultiValueUnnestingEnabled

      public boolean isMultiValueUnnestingEnabled()

    • withOverrides

      public GroupByQueryConfig withOverrides(GroupByQuery query)

    • toString

      public String toString()
      Overrides:
      toString in class Object