edu.iu.dsc.tws.task.cdfw

Class BaseDriver

java.lang.Object

edu.iu.dsc.tws.task.cdfw.BaseDriver

All Implemented Interfaces:

IDriver

Direct Known Subclasses:

BatchTSetBaseDriver, HelloExample.HelloDriver, KMeansConnectedDataflowExample.KMeansDriver, ParallelDataFlowsExample.ParallelDataflowsDriver, StreamTSetBaseDriver, TwoDataFlowsExample.TwoDataFlowsDriver

public abstract class BaseDriver
extends java.lang.Object
implements IDriver

Constructor Summary

Constructors

Constructor and Description
BaseDriver()

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,
abstract void	execute(CDFWEnv exec)
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	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

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

getMessages, getState

Constructor Detail

BaseDriver

public BaseDriver()

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

execute

public abstract void execute(CDFWEnv exec)

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