public class GroupByQueryConfig extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CTX_KEY_APPLY_LIMIT_PUSH_DOWN |
static String |
CTX_KEY_FORCE_LIMIT_PUSH_DOWN |
static String |
CTX_KEY_STRATEGY |
Constructor and Description |
---|
GroupByQueryConfig() |
Modifier and Type | Method and Description |
---|---|
int |
getBufferGrouperInitialBuckets() |
float |
getBufferGrouperMaxLoadFactor() |
int |
getBufferGrouperMaxSize() |
String |
getDefaultStrategy() |
int |
getIntermediateCombineDegree() |
int |
getMaxIntermediateRows() |
long |
getMaxMergingDictionarySize() |
long |
getMaxOnDiskStorage() |
int |
getMaxResults() |
int |
getNumParallelCombineThreads() |
boolean |
isForceHashAggregation() |
boolean |
isForcePushDownLimit() |
boolean |
isSingleThreaded() |
void |
setMaxIntermediateRows(int maxIntermediateRows) |
void |
setMaxResults(int maxResults) |
void |
setSingleThreaded(boolean singleThreaded) |
String |
toString() |
GroupByQueryConfig |
withOverrides(GroupByQuery query) |
public static final String CTX_KEY_STRATEGY
public static final String CTX_KEY_FORCE_LIMIT_PUSH_DOWN
public static final String CTX_KEY_APPLY_LIMIT_PUSH_DOWN
public String getDefaultStrategy()
public boolean isSingleThreaded()
public void setSingleThreaded(boolean singleThreaded)
public int getMaxIntermediateRows()
public void setMaxIntermediateRows(int maxIntermediateRows)
public int getMaxResults()
public void setMaxResults(int maxResults)
public int getBufferGrouperMaxSize()
public float getBufferGrouperMaxLoadFactor()
public int getBufferGrouperInitialBuckets()
public long getMaxMergingDictionarySize()
public long getMaxOnDiskStorage()
public boolean isForcePushDownLimit()
public boolean isForceHashAggregation()
public int getIntermediateCombineDegree()
public int getNumParallelCombineThreads()
public GroupByQueryConfig withOverrides(GroupByQuery query)
Copyright © 2011–2018. All rights reserved.