Package | Description |
---|---|
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.util |
Provides common utilities
|
Constructor and Description |
---|
DatafileStagingManager(FileClient client,
Path stagingLocation,
GUID jobId) |
Modifier and Type | Method and Description |
---|---|
GUID |
StoragePlanner.getGuid()
Returns the globally unique identifier for this StoragePlanner.
|
GUID |
StorageManagerSpecifier.getGuid()
Unique identifier, relative to the base path.
|
GUID |
JobInformation.getId()
Returns a unique identifier for the job
|
Constructor and Description |
---|
JobInformation(GUID id,
String name,
String userId)
Create a new job information object
|
Modifier and Type | Method and Description |
---|---|
GUID |
TaskNotFoundException.getTaskGUID() |
Constructor and Description |
---|
TaskNotFoundException(GUID taskGUID) |
Modifier and Type | Method and Description |
---|---|
String |
ClusterManagerImpl.allocateMaster(GUID jobGUID) |
String |
ClusterManager.allocateMaster(GUID jobGUID)
Allocates the master node for the given job
|
NodeAllocationPlan |
DataRushCluster.allocateWorkers(GUID jobGUID) |
NodeAllocationPlan |
ClusterManagerImpl.allocateWorkers(GUID jobGUID) |
NodeAllocationPlan |
ClusterManager.allocateWorkers(GUID jobGUID)
Allocates the worker nodes for the given job
|
CancelResult |
MonitoredFutureService.cancel(GUID resultGUID,
boolean mayInterruptIfRunning) |
CancelResult |
JobMasterServiceImpl.cancel(GUID guid,
boolean mayInterruptIfRunning) |
CancelResult |
DistributedWorkerServiceImpl.cancel(GUID guid,
boolean mayInterruptIfRunning) |
void |
JobScheduler.cancelJob(GUID jobID) |
void |
FIFOScheduler.cancelJob(GUID jobID) |
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 |
NodeUsageProvider.commitJobAllocation(GUID jobID,
String masterNode,
NodePartitionPlan partitions) |
void |
NodeAllocationContext.commitJobAllocation(GUID jobID,
String masterNode,
NodePartitionPlan partitions) |
void |
NodeManagerImpl.deleteJobLog(GUID jobId,
WorkerRole role) |
void |
NodeManager.deleteJobLog(GUID jobId,
WorkerRole role)
Deletes the log file for the given job.
|
boolean |
MonitoredFutureService.deleteResult(GUID guid) |
boolean |
JobMasterServiceImpl.deleteResult(GUID guid) |
boolean |
DistributedWorkerServiceImpl.deleteResult(GUID guid) |
void |
ClusterManagerImpl.failJob(GUID jobGUID) |
void |
ClusterManager.failJob(GUID jobGUID)
Manually force job fail
|
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
|
String |
NodeManagerImpl.getJobName(GUID jobId) |
String |
NodeManager.getJobName(GUID jobId)
Gets the name of the job with the provided id.
|
protected Integer |
ClusterManagerImpl.getJobServiceStatus(GUID jobGUID,
WorkerRole role) |
Integer |
ClusterManagerImpl.getJobStatus(GUID jobGUID) |
Integer |
ClusterManager.getJobStatus(GUID jobGUID)
Get the general run status of the job
-1 - job in progress
0 - job completed normally
1+ - job has errors
|
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.
|
JobLogInfo.LogInfo |
NodeManagerImpl.getNodeLogInfo(GUID jobId,
WorkerRole role) |
JobLogInfo.LogInfo |
NodeManager.getNodeLogInfo(GUID jobId,
WorkerRole role)
Get the log info for a job.
|
void |
ClusterManagerImpl.killJob(GUID jobGUID) |
void |
ClusterManager.killJob(GUID jobGUID)
Administrative job kill
|
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.
|
CommandStatus |
MonitoredFutureService.poll(GUID resultGUID,
long timeout,
TimeUnit timeunit) |
CommandStatus |
JobMasterServiceImpl.poll(GUID resultGUID,
long timeout,
TimeUnit timeunit) |
CommandStatus |
DistributedWorkerServiceImpl.poll(GUID resultGUID,
long timeout,
TimeUnit timeunit) |
Modifier and Type | Method and Description |
---|---|
GUID |
LogicalGraphInstanceView.getGraphInstanceGUID()
Uniquely identifies this graph instance, currently used for ui refresh on the client
|
Modifier and Type | Method and Description |
---|---|
static GUID |
GUID.next()
Generates a new unique identifier.
|
static GUID |
GUID.parse(String str)
Creates a new identifier from a string.
|
Copyright © 2016 Actian Corporation. All Rights Reserved.