edu.iu.dsc.tws.rsched.schedulers.mesos

Class MesosLauncher

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.mesos.MesosLauncher

All Implemented Interfaces:

ILauncher, java.lang.AutoCloseable

public class MesosLauncher
extends java.lang.Object
implements ILauncher

Launch a topology to mesos cluster

Constructor Summary

Constructors

Constructor and Description
MesosLauncher()

Method Summary

Modifier and Type	Method and Description
void	close() Cleanup any resources
void	initialize(Config mconfig) Initialize with the configuration
boolean	killJob(java.lang.String jobID) kill the submitted job
Twister2JobState	launch(JobAPI.Job job) Launch the processes according to the requested resources.

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosLauncher

public MesosLauncher()

Method Detail

initialize

public void initialize(Config mconfig)

Description copied from interface: ILauncher

Initialize with the configuration

Specified by:

initialize in interface ILauncher

Parameters:

mconfig - the configuration

close

public void close()

Description copied from interface: ILauncher

Cleanup any resources

Specified by:

close in interface ILauncher

Specified by:

close in interface java.lang.AutoCloseable

killJob

public boolean killJob(java.lang.String jobID)

Description copied from interface: ILauncher

kill the submitted job

Specified by:

killJob in interface ILauncher

launch

public Twister2JobState launch(JobAPI.Job job)

Description copied from interface: ILauncher

Launch the processes according to the requested resources.

Specified by:

launch in interface ILauncher

Returns:

true if the request is granted