edu.iu.dsc.tws.task.cdfw

Class CDFWEnv

java.lang.Object

edu.iu.dsc.tws.task.cdfw.CDFWEnv

public class CDFWEnv
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CDFWEnv(Config config, IScaler resourceScaler, IDriverMessenger driverMessenger, java.util.List<JobMasterAPI.WorkerInfo> workers)

Method Summary

Modifier and Type	Method and Description
void	allWorkersJoined(java.util.List<JobMasterAPI.WorkerInfo> workerList)
void	close()
boolean	decreaseWorkers(int workers)
void	executeDataFlowGraph(DataFlowGraph... dataFlowGraph)
void	executeDataFlowGraph(DataFlowGraph dataFlowGraph)
Config	getConfig()
java.util.List<JobMasterAPI.WorkerInfo>	getWorkerInfoList()
boolean	increaseWorkers(int workers)
void	workerMessageReceived(Any anyMessage, int senderWorkerID)

Methods inherited from class java.lang.Object

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

Constructor Detail

CDFWEnv

public CDFWEnv(Config config,
               IScaler resourceScaler,
               IDriverMessenger driverMessenger,
               java.util.List<JobMasterAPI.WorkerInfo> workers)

Method Detail

getConfig

public Config getConfig()

executeDataFlowGraph

public void executeDataFlowGraph(DataFlowGraph dataFlowGraph)

executeDataFlowGraph

public void executeDataFlowGraph(DataFlowGraph... dataFlowGraph)

increaseWorkers

public boolean increaseWorkers(int workers)

decreaseWorkers

public boolean decreaseWorkers(int workers)

getWorkerInfoList

public java.util.List<JobMasterAPI.WorkerInfo> getWorkerInfoList()

workerMessageReceived

public void workerMessageReceived(Any anyMessage,
                                  int senderWorkerID)

allWorkersJoined

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

close

public void close()