edu.iu.dsc.tws.rsched.worker

Class WorkerManager

java.lang.Object

edu.iu.dsc.tws.rsched.worker.WorkerManager

All Implemented Interfaces:

IJobMasterFailureListener, IWorkerFailureListener

public class WorkerManager
extends java.lang.Object
implements IWorkerFailureListener, IJobMasterFailureListener

Keep information about a managed environment where workers can get restarted.

Constructor Summary

Constructors

Constructor and Description
WorkerManager(Config config, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume, IWorker worker)

Method Summary

Modifier and Type	Method and Description
boolean	execute() Execute IWorker return false if IWorker fails fully after retries return true if execution successful throw an exception if execution fails and the worker needs to be restarted from jvm
void	failed(int wID) let the listener know that a worker failed
void	jmFailed() informs when the job master fails.
void	jmRestarted(java.lang.String jobMasterAddress) informs when the job master rejoins after failure
void	restarted(JobMasterAPI.WorkerInfo workerInfo) let the listener know that previously failed worker rejoined the job

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerManager

public WorkerManager(Config config,
                     JobAPI.Job job,
                     IWorkerController workerController,
                     IPersistentVolume persistentVolume,
                     IVolatileVolume volatileVolume,
                     IWorker worker)

Method Detail

execute

public boolean execute()

Execute IWorker return false if IWorker fails fully after retries return true if execution successful throw an exception if execution fails and the worker needs to be restarted from jvm

failed

public void failed(int wID)

Description copied from interface: IWorkerFailureListener

let the listener know that a worker failed

Specified by:

failed in interface IWorkerFailureListener

restarted

public void restarted(JobMasterAPI.WorkerInfo workerInfo)

Description copied from interface: IWorkerFailureListener

let the listener know that previously failed worker rejoined the job

Specified by:

restarted in interface IWorkerFailureListener

jmFailed

public void jmFailed()

Description copied from interface: IJobMasterFailureListener

informs when the job master fails.

Specified by:

jmFailed in interface IJobMasterFailureListener

jmRestarted

public void jmRestarted(java.lang.String jobMasterAddress)

Description copied from interface: IJobMasterFailureListener

informs when the job master rejoins after failure

Specified by:

jmRestarted in interface IJobMasterFailureListener