org.apache.oodt.cas.resource.mux

Class QueueMuxBatchManager

java.lang.Object

org.apache.oodt.cas.resource.mux.QueueMuxBatchManager

All Implemented Interfaces:

Batchmgr

public class QueueMuxBatchManager
extends Object
implements Batchmgr

Version:

$Revision$ A batch-manager used to execute and control jobs in a mesos-cluster.

Author:

starchmd

Constructor Summary

Constructors

Constructor and Description
QueueMuxBatchManager(BackendManager bm) ctor

Method Summary

Modifier and Type	Method and Description
boolean	executeRemotely(JobSpec job, ResourceNode resNode) Executes a job remotely on the specified remoteHost.
String	getExecutionNode(String jobId)
List<Job>	getJobsOnNode(String nodeId) Get a list of the ids of all jobs that are executing on the given node.
boolean	killJob(String jobId, ResourceNode node)
void	setBackendManager(BackendManager backend) Set the backend manager.
void	setJobRepository(JobRepository repository) Sets the JobRepository that this Batchmgr will use to persist Job information while Jobs are executing.
void	setMonitor(Monitor monitor) Sets the Monitor to be used by this Batchmgr.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueMuxBatchManager

public QueueMuxBatchManager(BackendManager bm)

ctor

Parameters:

bm - - backend manager

Method Detail

setBackendManager

public void setBackendManager(BackendManager backend)

Set the backend manager.

Parameters:

backend - - backend manager effectively mapping queue's to sets of backends.

executeRemotely

public boolean executeRemotely(JobSpec job,
                               ResourceNode resNode)
                        throws JobExecutionException

Description copied from interface: Batchmgr

Executes a job remotely on the specified remoteHost.

Specified by:

executeRemotely in interface Batchmgr

Parameters:

job - The JobSpec to execute.

Returns:

true if the job execution was successful, false otherwise.

Throws:

JobExecutionException - If there is an exception executing the job on the remote host.

setMonitor

public void setMonitor(Monitor monitor)

Description copied from interface: Batchmgr

Sets the Monitor to be used by this Batchmgr.

Specified by:

setMonitor in interface Batchmgr

Parameters:

monitor - The Monitor to be used.

getJobsOnNode

public List<Job> getJobsOnNode(String nodeId)

Description copied from interface: Batchmgr

Get a list of the ids of all jobs that are executing on the given node.

Specified by:

getJobsOnNode in interface Batchmgr

Returns:

A list of ids of jobs on the given node

setJobRepository

public void setJobRepository(JobRepository repository)

Description copied from interface: Batchmgr

Sets the JobRepository that this Batchmgr will use to persist Job information while Jobs are executing.

Specified by:

setJobRepository in interface Batchmgr

killJob

public boolean killJob(String jobId,
                       ResourceNode node)

Specified by:

killJob in interface Batchmgr

Returns:

getExecutionNode

public String getExecutionNode(String jobId)

Specified by:

getExecutionNode in interface Batchmgr

Returns: