public class MPIWorkerController extends java.lang.Object implements IWorkerController
Constructor and Description |
---|
MPIWorkerController(int workerID,
java.util.Map<java.lang.Integer,JobMasterAPI.WorkerInfo> workers,
int restartCount) |
Modifier and Type | Method and Description |
---|---|
boolean |
addAllJoinedListener(IAllJoinedListener iAllJoinedListener) |
java.util.List<JobMasterAPI.WorkerInfo> |
getAllWorkers()
get all workers in the job.
|
CheckpointingClient |
getCheckpointingClient() |
java.util.List<JobMasterAPI.WorkerInfo> |
getJoinedWorkers()
get all joined workers in this job, including the ones finished execution
if there are some workers that have not joined yet, they may not be included in this list.
|
int |
getNumberOfWorkers()
return the number of all workers in this job,
including non-started ones and finished ones
|
JobMasterAPI.WorkerInfo |
getWorkerInfo()
return the WorkerInfo object for this worker
|
JobMasterAPI.WorkerInfo |
getWorkerInfoForID(int id)
return the WorkerInfo object for the given ID
|
void |
waitOnBarrier()
wait for all workers in the job to arrive at this barrier
After waiting for the timeout specified in ControllerContext.maxWaitTimeOnBarrier
if some workers still could not arrive at the barrier, throw an exception
|
void |
waitOnBarrier(long timeLimit)
wait for all workers in the job to arrive at this barrier
After waiting for the timeLimit,
if some workers still could not arrive at the barrier, throw an exception
|
void |
waitOnInitBarrier()
this barrier is used when initializing the workers.
|
int |
workerRestartCount()
get worker restartCount
zero means starting for the first time
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getFailureListener
public MPIWorkerController(int workerID, java.util.Map<java.lang.Integer,JobMasterAPI.WorkerInfo> workers, int restartCount)
public JobMasterAPI.WorkerInfo getWorkerInfo()
IWorkerController
getWorkerInfo
in interface IWorkerController
public JobMasterAPI.WorkerInfo getWorkerInfoForID(int id)
IWorkerController
getWorkerInfoForID
in interface IWorkerController
public int getNumberOfWorkers()
IWorkerController
getNumberOfWorkers
in interface IWorkerController
public java.util.List<JobMasterAPI.WorkerInfo> getJoinedWorkers()
IWorkerController
getJoinedWorkers
in interface IWorkerController
public java.util.List<JobMasterAPI.WorkerInfo> getAllWorkers() throws TimeoutException
IWorkerController
return all workers in the job including the ones that have already left, if any
getAllWorkers
in interface IWorkerController
TimeoutException
public int workerRestartCount()
IWorkerController
workerRestartCount
in interface IWorkerController
public void waitOnBarrier() throws TimeoutException
IWorkerController
waitOnBarrier
in interface IWorkerController
TimeoutException
public void waitOnBarrier(long timeLimit) throws TimeoutException, JobFaultyException
IWorkerController
waitOnBarrier
in interface IWorkerController
TimeoutException
JobFaultyException
public void waitOnInitBarrier() throws TimeoutException
IWorkerController
waitOnInitBarrier
in interface IWorkerController
TimeoutException
public CheckpointingClient getCheckpointingClient()
getCheckpointingClient
in interface IWorkerController
public boolean addAllJoinedListener(IAllJoinedListener iAllJoinedListener)