public interface NodeManager extends ClasspathCacheManager
NodeManager
for creating engines to run remote portions of the graph on the managed
node.
End users should not be directly accessing NodeManager
objects; it is public for implementation purposes only.
Modifier and Type | Method and Description |
---|---|
boolean |
anyJobsRunning() |
void |
cleanup(GUID jobGUID,
WorkerRole role,
CleanupLevel level)
Cleans up files created for the job
|
void |
clearClasspathCache()
Clears the shared classpath cache
|
WorkerService |
createCommandExecutor(SerializationBridge<ClientWorkerServerArguments> arguments) |
void |
deleteJobLog(GUID jobId,
WorkerRole role)
Deletes the log file for the given job.
|
Map<String,String> |
getAllJobs()
Gets the id of every job log mapped to it's name that is managed by this node.
|
Integer |
getCommandServiceStatus(GUID jobGUID,
WorkerRole role)
Get the current status of the command service associated with the job and role
null - command service does not exist or has been terminated
-1 - command service still executing
0 - command service execution completed normally
1+ - command service execution completed with error
|
NodeConfiguration |
getConfiguration()
Gets the current configuration settings for the node.
|
String |
getJobName(GUID jobId)
Gets the name of the job with the provided id.
|
long |
getNodeLogAge(GUID jobId,
WorkerRole role)
Gets the age of the log files for the given job based on the last
modification date.
|
Map<String,Long> |
getNodeLogAge(WorkerRole role)
Gets the age of all log files based on the last modification
date mapped to job id.
|
JobLogInfo.LogInfo |
getNodeLogInfo(GUID jobId,
WorkerRole role)
Get the log info for a job.
|
Map<String,JobLogInfo.LogInfo> |
getNodeLogInfo(WorkerRole role)
Gets a map of all job ids linked with the node's log info.
|
List<NodeStatistics> |
getStatistics()
Fetches statistics from each of the live processes launched by this node manager
|
String |
getStatus()
Gets a description of the current status of the node
|
String |
getVersion()
Returns the version number of this NodeManager instance
|
NodeStatistics |
killJob(GUID jobGUID,
WorkerRole role)
Admin kill.
|
void |
notifyNodePreferencesChanged(ClusterPreferences nodeScopedPreferences)
Notifies the node manager that their preferences (may) have changed
|
InputStream |
openJobLogFile(GUID jobId,
WorkerRole role,
LogFileOptions options)
Opens the log file for the given job.
|
InputStream |
openNodeLogFile(LogFileOptions options)
Opens the log file for the node manager.
|
void |
rotateNodeLog()
Rotates the node manager log
|
void |
shutdown()
Terminates the node manager.
|
addToCache, notInNodeCache
String getStatus() throws RMIException
RMIException
- if an error occurs connecting to the NodeManagerNodeConfiguration getConfiguration() throws RMIException
RMIException
WorkerService createCommandExecutor(SerializationBridge<ClientWorkerServerArguments> arguments) throws RMIException
RMIException
boolean anyJobsRunning() throws RMIException
RMIException
void shutdown() throws RMIException
RMIException
List<NodeStatistics> getStatistics() throws RMIException
RMIException
Integer getCommandServiceStatus(GUID jobGUID, WorkerRole role)
jobGUID
- the job guidrole
- the role of the workerNodeStatistics killJob(GUID jobGUID, WorkerRole role) throws RMIException
jobGUID
- role
- the role of the worker to killRMIException
ClusterManager#killJob(GUID)}
void cleanup(GUID jobGUID, WorkerRole role, CleanupLevel level) throws RMIException
jobGUID
- the job guidlevel
- the cleanup level.RMIException
void notifyNodePreferencesChanged(ClusterPreferences nodeScopedPreferences) throws RMIException
nodeScopedPreferences
- the new preferencesRMIException
Map<String,String> getAllJobs()
String getJobName(GUID jobId)
Map<String,Long> getNodeLogAge(WorkerRole role)
role
- whether we want the log for the job master or the joblong getNodeLogAge(GUID jobId, WorkerRole role)
jobId
- information used to determine the name of the log filerole
- whether we want the log for the job master or the jobIOException
- if a failure happens reading the filesMap<String,JobLogInfo.LogInfo> getNodeLogInfo(WorkerRole role)
JobLogInfo.LogInfo getNodeLogInfo(GUID jobId, WorkerRole role)
jobId
- information used to determine the name of the log filerole
- whether we want the log for the job master or the jobInputStream openJobLogFile(GUID jobId, WorkerRole role, LogFileOptions options) throws RMIException, IOException
jobId
- information used to determine the name of the log filerole
- whether we want the log for the job master or the joboptions
- IOException
- if a failure happens reading the fileRMIException
void deleteJobLog(GUID jobId, WorkerRole role)
jobId
- information used to determine the name of the log filerole
- whether we want the log for the job master or the jobIOException
- if a failure happens deleting the fileInputStream openNodeLogFile(LogFileOptions options) throws RMIException, IOException
options
- IOException
RMIException
void clearClasspathCache() throws RMIException, IOException
IOException
- if unable to delete (would typically happen if job is running)RMIException
void rotateNodeLog() throws RMIException
RMIException
String getVersion()
Copyright © 2016 Actian Corporation. All Rights Reserved.