edu.iu.dsc.tws.rsched.job

Class Twister2Submitter

java.lang.Object

edu.iu.dsc.tws.rsched.job.Twister2Submitter

public final class Twister2Submitter
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	clearAllJobs(Config config) Clear left over resources for all checkpointed jobs that are not currently running: The Job package for the checkpointed job stored in user home directory Checkpointed data that are saved when jobs failed.
static void	clearJob(java.lang.String jobID, Config config)
static Twister2JobState	restartJob(java.lang.String jobID, Config config) Restart a Twister2 job
static void	submitJob(Twister2Job twister2Job)
static Twister2JobState	submitJob(Twister2Job twister2Job, Config config) Submit a Twister2 job
static void	terminateJob(java.lang.String jobID, Config config) terminate a Twister2 job

Methods inherited from class java.lang.Object

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

Method Detail

submitJob

public static void submitJob(Twister2Job twister2Job)

submitJob

public static Twister2JobState submitJob(Twister2Job twister2Job,
                                         Config config)

Submit a Twister2 job

Parameters:

twister2Job - job

restartJob

public static Twister2JobState restartJob(java.lang.String jobID,
                                          Config config)

Restart a Twister2 job

terminateJob

public static void terminateJob(java.lang.String jobID,
                                Config config)

terminate a Twister2 job

clearJob

public static void clearJob(java.lang.String jobID,
                            Config config)

clearAllJobs

public static void clearAllJobs(Config config)

Clear left over resources for all checkpointed jobs that are not currently running: The Job package for the checkpointed job stored in user home directory Checkpointed data that are saved when jobs failed.