edu.iu.dsc.tws.examples.internal.rsched

Class DriverExample

java.lang.Object

edu.iu.dsc.tws.examples.internal.rsched.DriverExample

All Implemented Interfaces:

IDriver

public class DriverExample
extends java.lang.Object
implements IDriver

Constructor Summary

Constructors

Constructor and Description
DriverExample()

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
void	sendCompleteMessage(IDriverMessenger messenger)
void	workerMessageReceived(Any anyMessage, int senderID) 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

Methods inherited from interface edu.iu.dsc.tws.api.driver.IDriver

getMessages, getState

Constructor Detail

DriverExample

public DriverExample()

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

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

sendCompleteMessage

public void sendCompleteMessage(IDriverMessenger messenger)

workerMessageReceived

public void workerMessageReceived(Any anyMessage,
                                  int senderID)

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