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:

  • Constructor Details

    • 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 Details

    • 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