edu.iu.dsc.tws.api.driver

Class DefaultDriver

java.lang.Object

edu.iu.dsc.tws.api.driver.DefaultDriver

All Implemented Interfaces:

IDriver

public class DefaultDriver
extends java.lang.Object
implements IDriver

Constructor Summary

Constructors

Constructor and Description
DefaultDriver()

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,
void	execute(Config config, IScaler scaler, IDriverMessenger messenger) After the job is submitted, an instance of this method will be executed in the Job Master
java.util.Map<java.lang.Integer,java.lang.String>	getMessages() get the messages sent by workers to this driver
DriverJobState	getState() returns the current state of the driver
void	workerMessageReceived(Any anyMessage, int senderWorkerID) received a protocol buffer message from a worker

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDriver

public DefaultDriver()

Method Detail

execute

public void execute(Config config,
                    IScaler scaler,
                    IDriverMessenger messenger)

Description copied from interface: IDriver

After the job is submitted, an instance of this method will be executed in the Job Master

Implementing Driver program can communicate with the workers through provided IDriverMessenger and it can scale up/down the number of workers in the job by using IScaler

Specified by:

execute in interface IDriver

workerMessageReceived

public void workerMessageReceived(Any anyMessage,
                                  int senderWorkerID)

Description copied from interface: IDriver

received a protocol buffer message from a worker

Specified by:

workerMessageReceived in interface IDriver

Parameters:

anyMessage - received message from the worker

allWorkersJoined

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

Description copied from interface: IDriver

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

Specified by:

allWorkersJoined in interface IDriver

getState

public DriverJobState getState()

Description copied from interface: IDriver

returns the current state of the driver

Specified by:

getState in interface IDriver

Returns:

the current state

getMessages

public java.util.Map<java.lang.Integer,java.lang.String> getMessages()

Description copied from interface: IDriver

get the messages sent by workers to this driver

Specified by:

getMessages in interface IDriver

Returns:

a map containing messages from each worker