edu.iu.dsc.tws.task.impl.cdfw

Class CDFWRuntime

java.lang.Object

edu.iu.dsc.tws.task.impl.cdfw.CDFWRuntime

All Implemented Interfaces:

IAllJoinedListener, IReceiverFromDriver, IScalerListener

public class CDFWRuntime
extends java.lang.Object
implements IReceiverFromDriver, IScalerListener, IAllJoinedListener

Constructor Summary

Constructors

Constructor and Description
CDFWRuntime(Config cfg, int wId, IWorkerController controller) Connected Dataflow Runtime

Method Summary

Modifier and Type	Method and Description
void	allWorkersJoined(java.util.List<JobMasterAPI.WorkerInfo> workerList) this method is invoked when all workers joined the job initially and also, after each scale up operation, when all new workers joined the job, it is invoked
void	driverMessageReceived(Any anyMessage) received a broadcast message from the driver
boolean	execute() execute
void	workersScaledDown(int instancesRemoved) called when new instances of workers are removed from the job
void	workersScaledUp(int instancesAdded) called when new instances of workers are added the job

Methods inherited from class java.lang.Object

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

Constructor Detail

CDFWRuntime

public CDFWRuntime(Config cfg,
                   int wId,
                   IWorkerController controller)

Connected Dataflow Runtime

Method Detail

execute

public boolean execute()

execute

driverMessageReceived

public void driverMessageReceived(Any anyMessage)

Description copied from interface: IReceiverFromDriver

received a broadcast message from the driver

Specified by:

driverMessageReceived in interface IReceiverFromDriver

Parameters:

anyMessage - received message from the driver

workersScaledUp

public void workersScaledUp(int instancesAdded)

Description copied from interface: IScalerListener

called when new instances of workers are added the job

Specified by:

workersScaledUp in interface IScalerListener

workersScaledDown

public void workersScaledDown(int instancesRemoved)

Description copied from interface: IScalerListener

called when new instances of workers are removed from the job

Specified by:

workersScaledDown in interface IScalerListener

allWorkersJoined

public void allWorkersJoined(java.util.List<JobMasterAPI.WorkerInfo> workerList)

Description copied from interface: IAllJoinedListener

this method is invoked when all workers joined the job initially and also, after each scale up operation, when all new workers joined the job, it is invoked

Specified by:

allWorkersJoined in interface IAllJoinedListener