Package org.apache.sysds.conf
Class ConfigurationManager
- java.lang.Object
-
- org.apache.sysds.conf.ConfigurationManager
-
public class ConfigurationManager extends Object
Singleton for accessing the parsed and merged system configuration. NOTE: parallel execution of multiple DML scripts (in the same JVM) with different configurations would require changes/extensions of this class.
-
-
Constructor Summary
Constructors Constructor Description ConfigurationManager()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
clearLocalConfigs()
Removes the thread-local dml and compiler configurations, leading to a reinitialization on the next get unless set in between.static int
getBlocksize()
static org.apache.hadoop.mapred.JobConf
getCachedJobConf()
Returns a cached JobConf object, intended for global use by all operations with read-only access to job conf.static CompilerConfig
getCompilerConfig()
Gets the current thread-local compiler configuration.static boolean
getCompilerConfigFlag(CompilerConfig.ConfigType key)
Get a boolean compiler config in a robust manner, returning false if config not existing.static Compression.CompressConfig
getCompressConfig()
static DMLConfig
getDMLConfig()
Gets the current thread-local dml configuration.static int
getFederatedTimeout()
static ILinearize.DagLinearization
getLinearizationOrder()
static int
getNumberTokenizeBlocks()
static int
getNumThreads()
static int
getParallelApplyBlocks()
static int
getParallelBuildBlocks()
static String
getScratchSpace()
static boolean
isAutoEvictionEnabled()
static boolean
isAutoLinearizationEnabled()
static boolean
isBroadcastEnabled()
static boolean
isCheckpointEnabled()
static boolean
isCodegenEnabled()
static boolean
isCompressionEnabled()
static boolean
isDynamicRecompilation()
static boolean
isFederatedReadCacheEnabled()
static boolean
isFederatedRuntimePlanner()
static boolean
isFederatedSSL()
static boolean
isMaxPrallelizeEnabled()
static boolean
isParallelIOEnabled()
static boolean
isParallelMatrixOperations()
static boolean
isParallelParFor()
static boolean
isParallelTokenize()
static boolean
isParallelTransform()
static boolean
isPrefetchEnabled()
static boolean
isRuleBasedGPUPlacement()
static boolean
isStagedParallelTransform()
static void
setCachedJobConf(org.apache.hadoop.mapred.JobConf job)
static void
setGlobalConfig(CompilerConfig conf)
static void
setGlobalConfig(DMLConfig conf)
Sets a global configuration as a basis for any thread-local configurations.static void
setLocalConfig(CompilerConfig conf)
Sets the current thread-local compiler configuration to the given config.static void
setLocalConfig(DMLConfig conf)
Sets the current thread-local dml configuration to the given config.
-
-
-
Method Detail
-
getCachedJobConf
public static org.apache.hadoop.mapred.JobConf getCachedJobConf()
Returns a cached JobConf object, intended for global use by all operations with read-only access to job conf. This prevents to read the hadoop conf files over and over again from classpath.- Returns:
- the cached JobConf
-
setCachedJobConf
public static void setCachedJobConf(org.apache.hadoop.mapred.JobConf job)
-
setGlobalConfig
public static void setGlobalConfig(DMLConfig conf)
Sets a global configuration as a basis for any thread-local configurations. NOTE: This global configuration should never be accessed directly but only through its thread-local derivatives.- Parameters:
conf
- the configuration
-
setLocalConfig
public static void setLocalConfig(DMLConfig conf)
Sets the current thread-local dml configuration to the given config.- Parameters:
conf
- the configuration
-
getDMLConfig
public static DMLConfig getDMLConfig()
Gets the current thread-local dml configuration.- Returns:
- the dml configuration
-
setGlobalConfig
public static void setGlobalConfig(CompilerConfig conf)
-
setLocalConfig
public static void setLocalConfig(CompilerConfig conf)
Sets the current thread-local compiler configuration to the given config.- Parameters:
conf
- the compiler configuration
-
clearLocalConfigs
public static void clearLocalConfigs()
Removes the thread-local dml and compiler configurations, leading to a reinitialization on the next get unless set in between.
-
getCompilerConfig
public static CompilerConfig getCompilerConfig()
Gets the current thread-local compiler configuration.- Returns:
- the compiler configuration
-
getCompilerConfigFlag
public static boolean getCompilerConfigFlag(CompilerConfig.ConfigType key)
Get a boolean compiler config in a robust manner, returning false if config not existing.- Parameters:
key
- config type- Returns:
- compiler config flag
-
getScratchSpace
public static String getScratchSpace()
-
getBlocksize
public static int getBlocksize()
-
isDynamicRecompilation
public static boolean isDynamicRecompilation()
-
isParallelMatrixOperations
public static boolean isParallelMatrixOperations()
-
isParallelTransform
public static boolean isParallelTransform()
-
isParallelTokenize
public static boolean isParallelTokenize()
-
isStagedParallelTransform
public static boolean isStagedParallelTransform()
-
getNumberTokenizeBlocks
public static int getNumberTokenizeBlocks()
-
getParallelApplyBlocks
public static int getParallelApplyBlocks()
-
getParallelBuildBlocks
public static int getParallelBuildBlocks()
-
getNumThreads
public static int getNumThreads()
-
isParallelParFor
public static boolean isParallelParFor()
-
isCodegenEnabled
public static boolean isCodegenEnabled()
-
isFederatedRuntimePlanner
public static boolean isFederatedRuntimePlanner()
-
isCompressionEnabled
public static boolean isCompressionEnabled()
-
getCompressConfig
public static Compression.CompressConfig getCompressConfig()
-
getFederatedTimeout
public static int getFederatedTimeout()
-
isFederatedSSL
public static boolean isFederatedSSL()
-
isFederatedReadCacheEnabled
public static boolean isFederatedReadCacheEnabled()
-
isPrefetchEnabled
public static boolean isPrefetchEnabled()
-
isMaxPrallelizeEnabled
public static boolean isMaxPrallelizeEnabled()
-
isAutoLinearizationEnabled
public static boolean isAutoLinearizationEnabled()
-
isParallelIOEnabled
public static boolean isParallelIOEnabled()
-
isBroadcastEnabled
public static boolean isBroadcastEnabled()
-
isCheckpointEnabled
public static boolean isCheckpointEnabled()
-
isRuleBasedGPUPlacement
public static boolean isRuleBasedGPUPlacement()
-
isAutoEvictionEnabled
public static boolean isAutoEvictionEnabled()
-
getLinearizationOrder
public static ILinearize.DagLinearization getLinearizationOrder()
-
-