edu.iu.dsc.tws.rsched.schedulers.k8s

Class KubernetesLauncher

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.k8s.KubernetesLauncher

All Implemented Interfaces:

ILauncher, java.lang.AutoCloseable

public class KubernetesLauncher
extends java.lang.Object
implements ILauncher

Constructor Summary

Constructors

Constructor and Description
KubernetesLauncher()

Method Summary

Modifier and Type	Method and Description
void	close() Close up any resources
void	initialize(Config conf) Initialize with the configuration
boolean	killJob(java.lang.String jobID) Kill the Kubernetes Job
Twister2JobState	launch(JobAPI.Job job) Launch the processes according to the resource plan.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLauncher

public KubernetesLauncher()

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)

Kill the Kubernetes Job

Specified by:

killJob in interface ILauncher