public abstract class DruidProcessingConfig extends ExecutorServiceConfig implements ColumnConfig
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_NUM_MERGE_BUFFERS |
DEFAULT_NUM_THREADS
Constructor and Description |
---|
DruidProcessingConfig() |
Modifier and Type | Method and Description |
---|---|
int |
columnCacheSizeBytes() |
int |
getNumMergeBuffers() |
int |
getNumMergeBuffersConfigured()
Returns the number of merge buffers _explicitly_ configured, or -1 if it is not explicitly configured, that is not
a valid number of buffers.
|
int |
getNumThreadsConfigured()
Returns the number of threads _explicitly_ configured, or -1 if it is not explicitly configured, that is not
a valid number of threads.
|
String |
getTmpDir() |
int |
intermediateComputeSizeBytes() |
boolean |
isFifo() |
int |
poolCacheMaxCount() |
getFormatString, getNumThreads
public static final int DEFAULT_NUM_MERGE_BUFFERS
public int intermediateComputeSizeBytes()
public int poolCacheMaxCount()
public int getNumThreadsConfigured()
ExecutorServiceConfig
ExecutorServiceConfig.getNumThreads()
.
This method exists for ability to distinguish between the default value set when there is no explicit config, and
an explicitly configured value.getNumThreadsConfigured
in class ExecutorServiceConfig
public int getNumMergeBuffers()
public int getNumMergeBuffersConfigured()
getNumMergeBuffers()
. This method exists for ability to distinguish between the default value set when there is
no explicit config, and an explicitly configured value.public int columnCacheSizeBytes()
columnCacheSizeBytes
in interface ColumnConfig
public boolean isFifo()
public String getTmpDir()
Copyright © 2011–2018. All rights reserved.