Module datarush.commons

Package com.pervasive.datarush.cal

Class JobSpecifier

java.lang.Object

com.pervasive.datarush.cal.JobSpecifier

All Implemented Interfaces:

Serializable

public final class JobSpecifier
extends Object
implements Serializable

Rollup of all parameters needed to launch a job

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
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

Method Summary

Modifier and Type	Method	Description
ClasspathSpecifier	classpath()	Returns the classpath of the job
JobSpecifier	classpath(ClasspathSpecifier classpath)	Overrides the classpath
ClusterSpecifier	cluster()	Returns the cluster on which to run the job
JobSpecifier	cluster(ClusterSpecifier cluster)	Overrides the cluster
List<String>	extensionPaths()	Returns the extension paths.
JobSpecifier	extensionPaths(List<String> extensionPaths)	Overrides the extension paths
JobInformation	jobInformation()	Returns basic job information (id, user id, etc).
JobSpecifier	jobInformation(JobInformation jobInformation)	Overrides the jobInformation
ResourceSpecifier	requestedResources()	Returns the resources requested for the job
String	schedulerQueue()	Returns the scheduler queue.
JobSpecifier	schedulerQueue(String schedulerQueue)	Overrides the scheduler queue
Path	storageManagementPath()	Returns the root scratch directory to use.
JobSpecifier	storageManagementPath(Path storageManagementPath)	Overrides the storageManagementPath

Methods inherited from class java.lang.Object

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

Constructor Detail

JobSpecifier

public JobSpecifier(ResourceSpecifier requestedResources,
                    ClusterSpecifier cluster,
                    ClasspathSpecifier classpath,
                    JobInformation jobInformation,
                    Path storageManagementPath)

Create a new job specifier

Parameters:

requestedResources - the requested resources for the job

cluster - the cluster on which to run the job

classpath - the classpath of the job

jobInformation - basic job information (user id, etc).

storageManagementPath - the storage managment path for the job

JobSpecifier

public JobSpecifier(ResourceSpecifier requestedResources,
                    ClusterSpecifier cluster,
                    ClasspathSpecifier classpath,
                    JobInformation jobInformation,
                    Path storageManagementPath,
                    String schedulerQueue,
                    List<String> extensionPaths)

Create a new job specifier

Parameters:

requestedResources - the requested resources for the job

cluster - the cluster on which to run the job

classpath - the classpath of the job

jobInformation - basic job information (user id, etc).

storageManagementPath - the storage managment path for the job

schedulerQueue - the scheduler queue

extensionPaths - list of user provided extension paths

Method Detail

requestedResources

public ResourceSpecifier requestedResources()

Returns the resources requested for the job

Returns:

the requested resources

storageManagementPath

public Path storageManagementPath()

Returns the root scratch directory to use. For distributed, this must be a shared filesystem accessible by all node in the cluster.

Returns:

the root scratch directory to use

cluster

public ClusterSpecifier cluster()

Returns the cluster on which to run the job

Returns:

the cluster

classpath

public ClasspathSpecifier classpath()

Returns the classpath of the job

Returns:

the classpath of the job

jobInformation

public JobInformation jobInformation()

Returns basic job information (id, user id, etc).

Returns:

basic job information

schedulerQueue

public String schedulerQueue()

Returns the scheduler queue.

Returns:

scheduler queue

extensionPaths

public List<String> extensionPaths()

Returns the extension paths.

Returns:

extension paths

cluster

public JobSpecifier cluster(ClusterSpecifier cluster)

Overrides the cluster

Parameters:

cluster - the new cluster

Returns:

a new specifier

classpath

public JobSpecifier classpath(ClasspathSpecifier classpath)

Overrides the classpath

Parameters:

classpath - the new classpath

Returns:

a new specifier

jobInformation

public JobSpecifier jobInformation(JobInformation jobInformation)

Overrides the jobInformation

Parameters:

jobInformation - the new jobInformation

Returns:

a new specifier

storageManagementPath

public JobSpecifier storageManagementPath(Path storageManagementPath)

Overrides the storageManagementPath

Parameters:

storageManagementPath - the new storageManagementPath

Returns:

a new specifier

schedulerQueue

public JobSpecifier schedulerQueue(String schedulerQueue)

Overrides the scheduler queue

Parameters:

schedulerQueue - the new scheduler queue

Returns:

a new specifier

extensionPaths

public JobSpecifier extensionPaths(List<String> extensionPaths)

Overrides the extension paths

Parameters:

extensionPaths - the new extension paths

Returns:

a new specifier