public class NodeConfiguration extends Object
NodeManager
daemon.Modifier and Type | Field and Description |
---|---|
protected ConfigurationMacros |
macros |
Modifier and Type | Method and Description |
---|---|
String |
getCgroupPath() |
ClasspathCacheDirectory |
getClasspathCacheDir() |
String |
getDRHome()
Gets the path to the installation directory for DataRush.
|
String |
getExecutorJVM()
Gets the JVM used to run fragment executors.
|
File[] |
getExecutorScratchDirectories()
Gets the scratch directory to which we should write temp files.
|
JobWorkingDirectory |
getExecutorWorkingDirectory(JobInformation jobInfo,
WorkerRole role)
Gets the working directory used for fragment executors.
|
File |
getExecutorWorkingDirectoryBase() |
String |
getHadoopHome() |
long |
getHeartbeatIntervalMillis() |
String |
getHost() |
String |
getLogFilePattern()
Gets the pattern used for the daemon's log file.
|
int |
getMaximumCPU()
Gets the maximum number of virtual cores that can be allocated on the node.
|
int |
getMaximumMemory()
Gets the maximum amount of memory, in MB, that can be allocated on the node.
|
String |
getNodeName() |
ProcessAuthenticationSettings |
getProcessAuthentication()
Gets the configuration to use for process-level authentication.
|
String |
getResourceLimitEnforcment() |
static void |
rotateLogs() |
protected final ConfigurationMacros macros
public String getNodeName()
public String getHost()
public String getDRHome()
public String getExecutorJVM()
public File getExecutorWorkingDirectoryBase()
public ClasspathCacheDirectory getClasspathCacheDir()
public JobWorkingDirectory getExecutorWorkingDirectory(JobInformation jobInfo, WorkerRole role)
This directory is relative to he machine on which the node manager is executing.
public File[] getExecutorScratchDirectories()
public int getMaximumCPU()
public int getMaximumMemory()
public String getHadoopHome()
public ProcessAuthenticationSettings getProcessAuthentication()
ProcessSubjectProvider
services to construct the subject for the process.public long getHeartbeatIntervalMillis()
public String getResourceLimitEnforcment()
public String getCgroupPath()
public static void rotateLogs()
public String getLogFilePattern()
Copyright © 2016 Actian Corporation. All Rights Reserved.