Modifier and Type | Method and Description |
---|---|
boolean |
XmlRpcBatchMgr.executeRemotely(JobSpec jobSpec,
ResourceNode resNode) |
boolean |
Batchmgr.executeRemotely(JobSpec job,
ResourceNode resNode)
Executes a job remotely on the specified
remoteHost . |
protected void |
XmlRpcBatchMgr.jobExecuting(JobSpec spec) |
protected void |
XmlRpcBatchMgr.jobFailure(JobSpec spec) |
protected void |
XmlRpcBatchMgr.jobKilled(JobSpec spec) |
protected void |
XmlRpcBatchMgr.jobSuccess(JobSpec spec) |
protected void |
XmlRpcBatchMgr.notifyMonitor(ResourceNode node,
JobSpec jobSpec) |
Constructor and Description |
---|
XmlRpcBatchMgrProxy(JobSpec jobSpec,
ResourceNode remoteHost,
XmlRpcBatchMgr par) |
Modifier and Type | Method and Description |
---|---|
JobSpec |
JobStack.getNextJob() |
JobSpec |
JobQueue.getNextJob()
Gets the next
JobSpec from the queue, and correspondingly removes
it from persitance. |
JobSpec |
FifoMappedJobQueue.getNextJob() |
JobSpec |
MappedJobQueue.getNextJob(String queueName)
Gets the next
JobSpec in the queue with the given name. |
JobSpec |
FifoMappedJobQueue.getNextJob(String queueName) |
Modifier and Type | Method and Description |
---|---|
List<JobSpec> |
MappedJobQueue.getQueuedJobs(String queueName)
Gets a list of all queued jobs that belong to the queue with the given
name.
|
List<JobSpec> |
FifoMappedJobQueue.getQueuedJobs(String queueName) |
Modifier and Type | Method and Description |
---|---|
String |
MappedJobQueue.addJob(JobSpec spec) |
String |
JobStack.addJob(JobSpec spec) |
String |
JobQueue.addJob(JobSpec spec)
Persists a
JobSpec to the queue. |
String |
FifoMappedJobQueue.addJob(JobSpec spec) |
void |
MappedJobQueue.promoteJob(JobSpec spec) |
void |
FifoMappedJobQueue.promoteJob(JobSpec spec) |
void |
MappedJobQueue.removeJob(JobSpec spec)
Removes the
JobSpec with the given ID from the queue. |
void |
FifoMappedJobQueue.removeJob(JobSpec spec) |
String |
MappedJobQueue.requeueJob(JobSpec spec) |
String |
JobStack.requeueJob(JobSpec spec) |
String |
JobQueue.requeueJob(JobSpec spec)
Re-adds a
JobSpec to the back of the queue. |
String |
FifoMappedJobQueue.requeueJob(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
JobSpec |
XStreamJobRepository.getJobById(String jobId) |
JobSpec |
MemoryJobRepository.getJobById(String jobId) |
JobSpec |
JobRepository.getJobById(String jobId) |
Modifier and Type | Method and Description |
---|---|
String |
XStreamJobRepository.addJob(JobSpec spec) |
String |
MemoryJobRepository.addJob(JobSpec spec) |
String |
JobRepository.addJob(JobSpec spec) |
String |
XStreamJobRepository.getStatus(JobSpec spec) |
String |
MemoryJobRepository.getStatus(JobSpec spec) |
String |
JobRepository.getStatus(JobSpec spec) |
boolean |
XStreamJobRepository.jobFinished(JobSpec spec) |
boolean |
MemoryJobRepository.jobFinished(JobSpec spec) |
boolean |
JobRepository.jobFinished(JobSpec spec) |
void |
XStreamJobRepository.removeJob(JobSpec spec) |
void |
MemoryJobRepository.removeJob(JobSpec spec) |
void |
JobRepository.removeJob(JobSpec spec) |
void |
XStreamJobRepository.updateJob(JobSpec spec) |
void |
MemoryJobRepository.updateJob(JobSpec spec) |
void |
JobRepository.updateJob(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueMuxBatchManager.executeRemotely(JobSpec job,
ResourceNode resNode) |
ResourceNode |
QueueMuxScheduler.nodeAvailable(JobSpec spec) |
boolean |
QueueMuxScheduler.schedule(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
ResourceNode |
Scheduler.nodeAvailable(JobSpec spec)
Returns the ResourceNode that is considered to be
most availablewithin our underlying set of resources for the given JobSpec. |
ResourceNode |
LRUScheduler.nodeAvailable(JobSpec spec) |
boolean |
Scheduler.schedule(JobSpec spec)
Schedules a job to be executed by a particular batch manager.
|
boolean |
LRUScheduler.schedule(JobSpec spec) |
Modifier and Type | Method and Description |
---|---|
JobSpec |
JobSpecSerializer.getJobSpec()
Get the JobSpec back.
|
Constructor and Description |
---|
JobSpecSerializer(JobSpec spec)
Set the variables to serialize them.
|
Modifier and Type | Method and Description |
---|---|
static JobSpec |
JobBuilder.buildJobSpec(File jobFile) |
static JobSpec |
JobBuilder.buildJobSpec(String jobFilePath) |
static JobSpec |
XmlStructFactory.getJobSpec(Node node) |
Copyright © 1999–2017 Apache OODT. All rights reserved.