edu.iu.dsc.tws.master.driver

Class Scaler

java.lang.Object

edu.iu.dsc.tws.master.driver.Scaler

All Implemented Interfaces:

IScaler

public class Scaler
extends java.lang.Object
implements IScaler

Constructor Summary

Constructors

Constructor and Description
Scaler(IScalerPerCluster clusterScaler, WorkerMonitor workerMonitor, ZKJobUpdater zkJobUpdater)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Scaler

public Scaler(IScalerPerCluster clusterScaler,
              WorkerMonitor workerMonitor,
              ZKJobUpdater zkJobUpdater)

Method Detail

isScalable

public boolean isScalable()

Description copied from interface: IScaler

whether this job is scalable

Specified by:

isScalable in interface IScaler

Returns:

true if scalable

scaleUpWorkers

public boolean scaleUpWorkers(int instancesToAdd)

Description copied from interface: IScaler

add new instances of workers to the job

Specified by:

scaleUpWorkers in interface IScaler

Returns:

true if successful

scaleDownWorkers

public boolean scaleDownWorkers(int instancesToRemove)

Description copied from interface: IScaler

remove some instances of the workers from the job

Specified by:

scaleDownWorkers in interface IScaler

Returns:

true if successful