io.druid.query

Class DruidProcessingConfig

java.lang.Object

io.druid.java.util.common.concurrent.ExecutorServiceConfig

io.druid.query.DruidProcessingConfig

All Implemented Interfaces:

ColumnConfig

public abstract class DruidProcessingConfig
extends ExecutorServiceConfig
implements ColumnConfig

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NUM_MERGE_BUFFERS

Fields inherited from class io.druid.java.util.common.concurrent.ExecutorServiceConfig

DEFAULT_NUM_THREADS

Constructor Summary

Constructors

Constructor and Description
DruidProcessingConfig()

Method Summary

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

Methods inherited from class io.druid.java.util.common.concurrent.ExecutorServiceConfig

getFormatString, getNumThreads

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NUM_MERGE_BUFFERS

public static final int DEFAULT_NUM_MERGE_BUFFERS

See Also:

Constant Field Values

Constructor Detail

DruidProcessingConfig

public DruidProcessingConfig()

Method Detail

intermediateComputeSizeBytes

public int intermediateComputeSizeBytes()

poolCacheMaxCount

public int poolCacheMaxCount()

getNumThreadsConfigured

public int getNumThreadsConfigured()

Description copied from class: ExecutorServiceConfig

Returns the number of threads _explicitly_ configured, or -1 if it is not explicitly configured, that is not a valid number of threads. To get the configured value or the default (valid) number, use 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.

Overrides:

getNumThreadsConfigured in class ExecutorServiceConfig

getNumMergeBuffers

public int getNumMergeBuffers()

getNumMergeBuffersConfigured

public 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. To get the configured value or the default (valid) number, use getNumMergeBuffers(). This method exists for ability to distinguish between the default value set when there is no explicit config, and an explicitly configured value.

columnCacheSizeBytes

public int columnCacheSizeBytes()

Specified by:

columnCacheSizeBytes in interface ColumnConfig

isFifo

public boolean isFifo()

getTmpDir

public String getTmpDir()