edu.iu.dsc.tws.master.server

Class JobFailureWatcher

java.lang.Object

edu.iu.dsc.tws.master.server.JobFailureWatcher

All Implemented Interfaces:

InitBarrierListener, IWorkerFailureListener

public class JobFailureWatcher
extends java.lang.Object
implements IWorkerFailureListener, InitBarrierListener

Constructor Summary

Constructors

Constructor and Description
JobFailureWatcher()

Method Summary

Modifier and Type	Method and Description
void	addJobFaultListener(JobFaultListener jobFaultListener)
void	allArrived() this is only called for INIT barrier
void	failed(int workerID) let the listener know that a worker failed
boolean	isJobFaulty()
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

JobFailureWatcher

public JobFailureWatcher()

Method Detail

isJobFaulty

public boolean isJobFaulty()

addJobFaultListener

public void addJobFaultListener(JobFaultListener jobFaultListener)

allArrived

public void allArrived()

this is only called for INIT barrier

Specified by:

allArrived in interface InitBarrierListener

failed

public void failed(int workerID)

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