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

Class MesosScaler

java.lang.Object

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

All Implemented Interfaces:

IScalerPerCluster

public class MesosScaler
extends java.lang.Object
implements IScalerPerCluster

Constructor Summary

Constructors

Constructor and Description
MesosScaler(Config config, JobAPI.Job job, MesosController mesosController)

Method Summary

Modifier and Type	Method and Description
boolean	isScalable() whether this job is scalable
boolean	scaleDownWorkers(int instancesToRemove, int numberOfWorkers) remove workers from the scalable compute resource
boolean	scaleUpWorkers(int instancesToAdd) add new workers to the scalable compute resource
void	setFrameWorkId(java.lang.String id)

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosScaler

public MesosScaler(Config config,
                   JobAPI.Job job,
                   MesosController mesosController)

Method Detail

isScalable

public boolean isScalable()

Description copied from interface: IScalerPerCluster

whether this job is scalable

Specified by:

isScalable in interface IScalerPerCluster

Returns:

true if scalable

scaleUpWorkers

public boolean scaleUpWorkers(int instancesToAdd)

add new workers to the scalable compute resource

Specified by:

scaleUpWorkers in interface IScalerPerCluster

Returns:

scaleDownWorkers

public boolean scaleDownWorkers(int instancesToRemove,
                                int numberOfWorkers)

remove workers from the scalable compute resource

Specified by:

scaleDownWorkers in interface IScalerPerCluster

Parameters:

instancesToRemove -

numberOfWorkers - number of workers before the scale down

Returns:

setFrameWorkId

public void setFrameWorkId(java.lang.String id)