Package org.teiid.dqp.internal.process
Class DQPConfiguration
- java.lang.Object
-
- org.teiid.dqp.internal.process.DQPConfiguration
-
- Direct Known Subclasses:
DQPCoreService
,EmbeddedConfiguration
public class DQPConfiguration extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_MAX_ACTIVE_PLANS
static int
DEFAULT_MAX_PROCESS_WORKERS
static int
DEFAULT_MAX_SOURCE_ROWS
static int
DEFAULT_MAX_STALENESS_SECONDS
static int
DEFAULT_USER_REQUEST_SOURCE_CONCURRENCY
-
Constructor Summary
Constructors Constructor Description DQPConfiguration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AuthorizationValidator
getAuthorizationValidator()
int
getLobChunkSizeInKB()
int
getMaxActivePlans()
int
getMaxRowsFetchSize()
int
getMaxSourceRows()
Maximum source set rows to fetchint
getMaxThreads()
PreParser
getPreParser()
Properties
getProperties()
Get the properties used to initialize the engineOptions
.long
getQueryThresholdInMilli()
int
getQueryThresholdInSecs()
long
getQueryTimeout()
TeiidExecutor
getTeiidExecutor()
int
getTimeSliceInMilli()
int
getUserRequestSourceConcurrency()
boolean
isDetectingChangeEvents()
boolean
isExceptionOnMaxSourceRows()
Throw exception if there are more rows in the result set than specified in the MaxSourceRows setting.void
setAuthorizationValidator(AuthorizationValidator authorizationValidator)
void
setDetectingChangeEvents(boolean detectingChangeEvents)
void
setExceptionOnMaxSourceRows(boolean exceptionOnMaxSourceRows)
void
setLobChunkSizeInKB(int lobChunkSizeInKB)
void
setMaxActivePlans(int maxActivePlans)
void
setMaxRowsFetchSize(int maxRowsFetchSize)
void
setMaxSourceRows(int maxSourceRows)
void
setMaxThreads(int maxThreads)
void
setPreParser(PreParser preParser)
void
setProperties(Properties properties)
Set the properties used to initialize the engineOptions
void
setQueryThresholdInMilli(long queryThreshold)
void
setQueryThresholdInSecs(int queryThresholdInSecs)
void
setQueryTimeout(long queryTimeout)
void
setTimeSliceInMilli(int timeSliceInMilli)
void
setUserRequestSourceConcurrency(int userRequestSourceConcurrency)
-
-
-
Field Detail
-
DEFAULT_MAX_PROCESS_WORKERS
public static final int DEFAULT_MAX_PROCESS_WORKERS
- See Also:
- Constant Field Values
-
DEFAULT_MAX_SOURCE_ROWS
public static final int DEFAULT_MAX_SOURCE_ROWS
- See Also:
- Constant Field Values
-
DEFAULT_MAX_ACTIVE_PLANS
public static final int DEFAULT_MAX_ACTIVE_PLANS
- See Also:
- Constant Field Values
-
DEFAULT_USER_REQUEST_SOURCE_CONCURRENCY
public static final int DEFAULT_USER_REQUEST_SOURCE_CONCURRENCY
- See Also:
- Constant Field Values
-
DEFAULT_MAX_STALENESS_SECONDS
public static final int DEFAULT_MAX_STALENESS_SECONDS
- See Also:
- Constant Field Values
-
-
Method Detail
-
getMaxActivePlans
public int getMaxActivePlans()
-
setMaxActivePlans
public void setMaxActivePlans(int maxActivePlans)
-
getUserRequestSourceConcurrency
public int getUserRequestSourceConcurrency()
-
setUserRequestSourceConcurrency
public void setUserRequestSourceConcurrency(int userRequestSourceConcurrency)
-
getMaxThreads
public int getMaxThreads()
-
setMaxThreads
public void setMaxThreads(int maxThreads)
-
getTimeSliceInMilli
public int getTimeSliceInMilli()
-
setTimeSliceInMilli
public void setTimeSliceInMilli(int timeSliceInMilli)
-
getMaxRowsFetchSize
public int getMaxRowsFetchSize()
-
setMaxRowsFetchSize
public void setMaxRowsFetchSize(int maxRowsFetchSize)
-
getLobChunkSizeInKB
public int getLobChunkSizeInKB()
-
setLobChunkSizeInKB
public void setLobChunkSizeInKB(int lobChunkSizeInKB)
-
getQueryThresholdInSecs
public int getQueryThresholdInSecs()
-
getQueryThresholdInMilli
public long getQueryThresholdInMilli()
-
setQueryThresholdInMilli
public void setQueryThresholdInMilli(long queryThreshold)
-
setQueryThresholdInSecs
public void setQueryThresholdInSecs(int queryThresholdInSecs)
-
isExceptionOnMaxSourceRows
public boolean isExceptionOnMaxSourceRows()
Throw exception if there are more rows in the result set than specified in the MaxSourceRows setting.- Returns:
-
setExceptionOnMaxSourceRows
public void setExceptionOnMaxSourceRows(boolean exceptionOnMaxSourceRows)
-
getMaxSourceRows
public int getMaxSourceRows()
Maximum source set rows to fetch- Returns:
-
setMaxSourceRows
public void setMaxSourceRows(int maxSourceRows)
-
getAuthorizationValidator
public AuthorizationValidator getAuthorizationValidator()
-
setAuthorizationValidator
public void setAuthorizationValidator(AuthorizationValidator authorizationValidator)
-
isDetectingChangeEvents
public boolean isDetectingChangeEvents()
-
setDetectingChangeEvents
public void setDetectingChangeEvents(boolean detectingChangeEvents)
-
setQueryTimeout
public void setQueryTimeout(long queryTimeout)
-
getQueryTimeout
public long getQueryTimeout()
-
getTeiidExecutor
public TeiidExecutor getTeiidExecutor()
-
setPreParser
public void setPreParser(PreParser preParser)
-
getPreParser
public PreParser getPreParser()
-
getProperties
public Properties getProperties()
Get the properties used to initialize the engineOptions
. Defaults to the System properties.
-
setProperties
public void setProperties(Properties properties)
Set the properties used to initialize the engineOptions
- Parameters:
properties
-
-
-