edu.iu.dsc.tws.rsched.utils

Class JobUtils

java.lang.Object

edu.iu.dsc.tws.rsched.utils.JobUtils

public final class JobUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.lang.String	computeResourcesToPrint(JobAPI.Job job)
static java.lang.String	createJobPackageFileName(java.lang.String jobID)
static JobAPI.ComputeResource	getComputeResource(JobAPI.Job job, int index) return the ComputeResource with the given index if not found, return null
static java.lang.String	getJobDescriptionFilePath(java.lang.String jobFileName, Config config)
static java.lang.String	getJobDescriptionFilePath(java.lang.String workingDirectory, java.lang.String jobFileName, Config config)
static IWorker	initializeIWorker(JobAPI.Job job) if the worker class is an instance of IWorker initialize that if
static boolean	isJobScalable(Config config, JobAPI.Job job) For the job to be scalable: Driver class shall be specified a scalable compute resource shall be given itshould not be an openMPI job
static java.lang.String	jobClassPath(Config cfg, JobAPI.Job job, java.lang.String wd)
static Config	overrideConfigs(JobAPI.Job job, Config config) [Deprecated Function]
static java.util.Map<java.lang.String,java.lang.Object>	readCommandLineOpts()
static JobAPI.Job	readJobFile(java.lang.String fileName) Read the job file
static java.lang.String	systemClassPath(Config cfg)
static java.lang.String	toString(JobAPI.Job job)
static Config	updateConfigs(JobAPI.Job job, Config config) write the values from Job object to config object
static boolean	writeJobFile(JobAPI.Job job, java.lang.String fileName) Write the job file

Methods inherited from class java.lang.Object

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

Method Detail

writeJobFile

public static boolean writeJobFile(JobAPI.Job job,
                                   java.lang.String fileName)

Write the job file

readJobFile

public static JobAPI.Job readJobFile(java.lang.String fileName)

Read the job file

readCommandLineOpts

public static java.util.Map<java.lang.String,java.lang.Object> readCommandLineOpts()

jobClassPath

public static java.lang.String jobClassPath(Config cfg,
                                            JobAPI.Job job,
                                            java.lang.String wd)

systemClassPath

public static java.lang.String systemClassPath(Config cfg)

overrideConfigs

public static Config overrideConfigs(JobAPI.Job job,
                                     Config config)

[Deprecated Function]

getJobDescriptionFilePath

public static java.lang.String getJobDescriptionFilePath(java.lang.String workingDirectory,
                                                         java.lang.String jobFileName,
                                                         Config config)

getJobDescriptionFilePath

public static java.lang.String getJobDescriptionFilePath(java.lang.String jobFileName,
                                                         Config config)

updateConfigs

public static Config updateConfigs(JobAPI.Job job,
                                   Config config)

write the values from Job object to config object

getComputeResource

public static JobAPI.ComputeResource getComputeResource(JobAPI.Job job,
                                                        int index)

return the ComputeResource with the given index if not found, return null

toString

public static java.lang.String toString(JobAPI.Job job)

computeResourcesToPrint

public static java.lang.String computeResourcesToPrint(JobAPI.Job job)

createJobPackageFileName

public static java.lang.String createJobPackageFileName(java.lang.String jobID)

isJobScalable

public static boolean isJobScalable(Config config,
                                    JobAPI.Job job)

For the job to be scalable: Driver class shall be specified a scalable compute resource shall be given itshould not be an openMPI job

initializeIWorker

public static IWorker initializeIWorker(JobAPI.Job job)

if the worker class is an instance of IWorker initialize that if

Parameters:

job -

Returns: