Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.monitoring | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
WorkerRole |
JobServerInformation.getRole() |
static WorkerRole |
WorkerRole.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static WorkerRole[] |
WorkerRole.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
JobServerInformation(JobInformation jobInfo,
WorkerRole role,
ResourceAllocation resources) |
Modifier and Type | Method and Description |
---|---|
WorkerRole |
NodeStatisticsSnapshot.getWorkerRole() |
WorkerRole |
NodeStatistics.getWorkerRole() |
Modifier and Type | Method and Description |
---|---|
WorkerRole |
CacheScope.getRole() |
Modifier and Type | Method and Description |
---|---|
List<WorkerRole> |
NodeMapping.Entry.getAllowedRoles() |
Modifier and Type | Method and Description |
---|---|
void |
NodeManagerImpl.cleanup(GUID jobGUID,
WorkerRole role,
CleanupLevel level) |
void |
NodeManager.cleanup(GUID jobGUID,
WorkerRole role,
CleanupLevel level)
Cleans up files created for the job
|
void |
NodeManagerImpl.deleteJobLog(GUID jobId,
WorkerRole role) |
void |
NodeManager.deleteJobLog(GUID jobId,
WorkerRole role)
Deletes the log file for the given job.
|
Integer |
NodeManagerImpl.getCommandServiceStatus(GUID guid,
WorkerRole role) |
Integer |
NodeManager.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
|
JobWorkingDirectory |
NodeConfiguration.getExecutorWorkingDirectory(JobInformation jobInfo,
WorkerRole role)
Gets the working directory used for fragment executors.
|
protected Integer |
ClusterManagerImpl.getJobServiceStatus(GUID jobGUID,
WorkerRole role) |
long |
NodeManagerImpl.getNodeLogAge(GUID jobId,
WorkerRole role) |
long |
NodeManager.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> |
NodeManagerImpl.getNodeLogAge(WorkerRole role) |
Map<String,Long> |
NodeManager.getNodeLogAge(WorkerRole role)
Gets the age of all log files based on the last modification
date mapped to job id.
|
JobLogInfo.LogInfo |
NodeManagerImpl.getNodeLogInfo(GUID jobId,
WorkerRole role) |
JobLogInfo.LogInfo |
NodeManager.getNodeLogInfo(GUID jobId,
WorkerRole role)
Get the log info for a job.
|
Map<String,JobLogInfo.LogInfo> |
NodeManagerImpl.getNodeLogInfo(WorkerRole role) |
Map<String,JobLogInfo.LogInfo> |
NodeManager.getNodeLogInfo(WorkerRole role)
Gets a map of all job ids linked with the node's log info.
|
static CacheScope |
CacheScope.job(JobInformation job,
WorkerRole role) |
ClasspathCacheDirectory |
ClasspathCacheManagerImpl.CacheStorageConfiguration.jobCache(JobInformation jobScope,
WorkerRole role) |
ClasspathCacheDirectory |
ClasspathCacheManagerImpl.FileSystemCacheStorage.jobCache(JobInformation jobScope,
WorkerRole role) |
NodeStatistics |
NodeManagerImpl.killJob(GUID guid,
WorkerRole role) |
NodeStatistics |
NodeManager.killJob(GUID jobGUID,
WorkerRole role)
Admin kill.
|
InputStream |
NodeManagerImpl.openJobLogFile(GUID jobId,
WorkerRole role,
LogFileOptions options) |
InputStream |
NodeManager.openJobLogFile(GUID jobId,
WorkerRole role,
LogFileOptions options)
Opens the log file for the given job.
|
ClasspathSpecifier |
ClasspathCacheManagerImpl.resolve(JobInformation jobInfo,
WorkerRole role,
JobClasspathConfig cp) |
Constructor and Description |
---|
ClasspathSynchronizer(FileClient fileClient,
ClasspathSpecifier classpath,
JobInformation jobInfo,
WorkerRole role,
ParallelStartupHelper parallelStarter) |
Copyright © 2016 Actian Corporation. All Rights Reserved.