edu.iu.dsc.tws.rsched.schedulers.aurora

Class AuroraLauncher

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.aurora.AuroraLauncher

All Implemented Interfaces:

ILauncher, java.lang.AutoCloseable

public class AuroraLauncher
extends java.lang.Object
implements ILauncher

submit a job to Aurora Scheduler using AuroraClientController

Constructor Summary

Constructors

Constructor and Description
AuroraLauncher()

Method Summary

Modifier and Type	Method and Description
void	close() Close up any resources
static java.util.Map<AuroraField,java.lang.String>	constructEnvVariables(Config config, JobAPI.Job job) put relevant config parameters to a HashMap to be used as environment variables when submitting jobs
void	initialize(Config conf) Initialize with the configuration
boolean	killJob(java.lang.String jobID) Terminate the Aurora Job
Twister2JobState	launch(JobAPI.Job job) Launch the processes according to the resource plan.
static void	logEnvVariables(java.util.Map<AuroraField,java.lang.String> envs) print all environment variables for debugging purposes

Methods inherited from class java.lang.Object

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

Constructor Detail

AuroraLauncher

public AuroraLauncher()

Method Detail

initialize

public void initialize(Config conf)

Description copied from interface: ILauncher

Initialize with the configuration

Specified by:

initialize in interface ILauncher

Parameters:

conf - the configuration

launch

public Twister2JobState launch(JobAPI.Job job)

Launch the processes according to the resource plan.

Specified by:

launch in interface ILauncher

Returns:

true if the request is granted

close

public void close()

Close up any resources

Specified by:

close in interface ILauncher

Specified by:

close in interface java.lang.AutoCloseable

killJob

public boolean killJob(java.lang.String jobID)

Terminate the Aurora Job

Specified by:

killJob in interface ILauncher

constructEnvVariables

public static java.util.Map<AuroraField,java.lang.String> constructEnvVariables(Config config,
                                                                                JobAPI.Job job)

put relevant config parameters to a HashMap to be used as environment variables when submitting jobs

Parameters:

config -

Returns:

logEnvVariables

public static void logEnvVariables(java.util.Map<AuroraField,java.lang.String> envs)

print all environment variables for debugging purposes

Parameters:

envs -