Package | Description |
---|---|
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
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 |
---|---|
static JobInformation |
JobInformation.defaultJobInformation()
Create a job information object for a new job with default settings.
|
JobInformation |
JobServerInformation.getJobInformation() |
JobInformation |
JobExecutorService.getJobInformation()
Returns the job information associated with this service
|
JobInformation |
JobSpecifier.jobInformation()
Returns basic job information (id, user id, etc).
|
Modifier and Type | Method and Description |
---|---|
JobSpecifier |
JobSpecifier.jobInformation(JobInformation jobInformation)
Overrides the jobInformation
|
Constructor and Description |
---|
JobServerInformation(JobInformation jobInfo,
WorkerRole role,
ResourceAllocation resources) |
JobSpecifier(ResourceSpecifier requestedResources,
ClusterSpecifier cluster,
ClasspathSpecifier classpath,
JobInformation jobInformation,
Path storageManagementPath)
Create a new job specifier
|
JobSpecifier(ResourceSpecifier requestedResources,
ClusterSpecifier cluster,
ClasspathSpecifier classpath,
JobInformation jobInformation,
Path storageManagementPath,
String schedulerQueue,
List<String> extensionPaths)
Create a new job specifier
|
Modifier and Type | Method and Description |
---|---|
JobInformation |
AbstractDRJobExecutor.getJobInformation() |
Modifier and Type | Method and Description |
---|---|
JobInformation |
JobStatistics.getJobInfo() |
JobInformation |
NodeStatisticsSnapshot.getJobInformation() |
JobInformation |
NodeStatistics.getJobInformation()
Returns the job information for the job that running in this node
|
Modifier and Type | Method and Description |
---|---|
static JobStatistics |
JobStatistics.forNodeStatistics(JobStatus status,
JobInformation jobInfo,
List<NodeStatistics> nodeStatistics) |
static JobStatistics |
JobStatistics.forNodeStatistics(String jobID,
JobStatus status,
JobInformation jobInfo,
List<NodeStatistics> nodeStatistics) |
Modifier and Type | Method and Description |
---|---|
static List<JobStatistics> |
JobStatistics.multiJobStatistics(JobStatus status,
List<NodeStatistics> nodeStatistics,
List<JobInformation> allocatedJobs) |
Modifier and Type | Method and Description |
---|---|
JobInformation |
CacheScope.getJob() |
JobInformation |
NodeAllocationRequest.getJobInformation() |
JobInformation |
MasterDescriptor.getJobInformation()
Dataflow specific job information.
|
Modifier and Type | Method and Description |
---|---|
List<JobInformation> |
ClusterManagerImpl.getAllocatedJobs() |
List<JobInformation> |
ClusterManager.getAllocatedJobs() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManagerImpl.addContainersToAppMaster(JobInformation jobInfo,
List<ContainerDescriptor> containers) |
void |
ClusterManager.addContainersToAppMaster(JobInformation jobInfo,
List<ContainerDescriptor> containers)
Add descriptors of containers that are allocated to the application master.
|
void |
ClusterManagerImpl.deregisterAppMaster(JobInformation jobInfo) |
void |
ClusterManager.deregisterAppMaster(JobInformation jobInfo)
Deregister an external application master.
|
JobWorkingDirectory |
NodeConfiguration.getExecutorWorkingDirectory(JobInformation jobInfo,
WorkerRole role)
Gets the working directory used for fragment executors.
|
static CacheScope |
CacheScope.job(JobInformation job,
WorkerRole role) |
ClasspathCacheDirectory |
ClasspathCacheManagerImpl.CacheStorageConfiguration.jobCache(JobInformation jobScope,
WorkerRole role) |
ClasspathCacheDirectory |
ClasspathCacheManagerImpl.FileSystemCacheStorage.jobCache(JobInformation jobScope,
WorkerRole role) |
ClasspathSpecifier |
ClasspathCacheManagerImpl.resolve(JobInformation jobInfo,
WorkerRole role,
JobClasspathConfig cp) |
Constructor and Description |
---|
ClasspathSynchronizer(FileClient fileClient,
ClasspathSpecifier classpath,
JobInformation jobInfo,
WorkerRole role,
ParallelStartupHelper parallelStarter) |
MasterDescriptor(String applicationID,
String containerID,
String logHTTPAddr,
JobInformation jobInfo,
ResourceSpecifier requestedResources,
String host,
InetSocketAddress appMasterAddress,
long submissionTime) |
NodeAllocationRequest(JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
NodeAllocationRequest(long submitTime,
JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
NodeAllocationRequest(String jobID,
long submitTime,
JobInformation jobInformation,
ResourceSpecifier resources,
NodeAllocationStrategy strategy) |
Copyright © 2015 Actian Corporation. All Rights Reserved.