edu.iu.dsc.tws.rsched.core

Class ResourceAllocator

java.lang.Object

edu.iu.dsc.tws.rsched.core.ResourceAllocator

public class ResourceAllocator
extends java.lang.Object

This is the main class that allocates the resources and starts the processes required

These are the steps for submitting a job

1. Figure out the environment from the place where this is executed
2. We will take properties from java system < environment < job
3. Create the job information file and save it
4. Create a job package with jars and job information file to be uploaded to the cluster

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.logging.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
ResourceAllocator(Config config, JobAPI.Job job)

Method Summary

Modifier and Type	Method and Description
void	clearTemporaryFiles(java.lang.String jobDirectory) clear temporary files
static Config	getDefaultConfig() Returns the default configuration
static void	killJob(java.lang.String jobID, Config cnfg) Kill the job
static Config	loadConfig(java.util.Map<java.lang.String,java.lang.Object> cfg) loadConfig from config files and also from environment variables
Twister2JobState	resubmitJob() Resubmit the job to the cluster
Twister2JobState	submitJob() Submit the job to the cluster

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final java.util.logging.Logger LOG

Constructor Detail

ResourceAllocator

public ResourceAllocator(Config config,
                         JobAPI.Job job)

Method Detail

loadConfig

public static Config loadConfig(java.util.Map<java.lang.String,java.lang.Object> cfg)

loadConfig from config files and also from environment variables

Parameters:

cfg - the config values in this map will be put into returned Config

getDefaultConfig

public static Config getDefaultConfig()

Returns the default configuration

submitJob

public Twister2JobState submitJob()

Submit the job to the cluster

resubmitJob

public Twister2JobState resubmitJob()

Resubmit the job to the cluster

clearTemporaryFiles

public void clearTemporaryFiles(java.lang.String jobDirectory)

clear temporary files

Parameters:

jobDirectory - the name of the folder to be cleaned

killJob

public static void killJob(java.lang.String jobID,
                           Config cnfg)

Kill the job

Parameters:

jobID - of the job to kill