edu.iu.dsc.tws.api.driver

Interface IScalerPerCluster

All Known Implementing Classes:

K8sScaler, MesosScaler, NullScaler

public interface IScalerPerCluster

An interface that scales up/down the number of workers in a Twister2 job in a specific cluster An implementtaion of this interface will be written for each cluster such as Kubernetes, Mesos, Slurm, Nomad, etc

Method Summary

Modifier and Type	Method and Description
boolean	isScalable() whether this job is scalable
boolean	scaleDownWorkers(int instancesToRemove, int numberOfWorkers) remove some instances of the workers from the job
boolean	scaleUpWorkers(int instancesToAdd) add new instances of workers to the job

Method Detail

isScalable

boolean isScalable()

whether this job is scalable

Returns:

true if scalable

scaleUpWorkers

boolean scaleUpWorkers(int instancesToAdd)

add new instances of workers to the job

Parameters:

instancesToAdd -

Returns:

true if successful

scaleDownWorkers

boolean scaleDownWorkers(int instancesToRemove,
                         int numberOfWorkers)

remove some instances of the workers from the job

Parameters:

instancesToRemove -

numberOfWorkers - number of workers before the scale down

Returns:

true if successful