public class JobProgressImpl extends JobProgress
JobProgress.JobStatus
faultAcceptors, jobStatus, restartedWorkers, workerExecuteCount
Constructor and Description |
---|
JobProgressImpl() |
Modifier and Type | Method and Description |
---|---|
static void |
faultOccurred(int wID)
this method must be called exactly once for each fault
if there are multiple faults without restoring back to the normal in the middle,
it must be called once only
|
static void |
increaseWorkerExecuteCount() |
static void |
init() |
static void |
setJobStatus(JobProgress.JobStatus jobStatus1) |
static void |
setRestartedWorkers(java.util.Collection<JobMasterAPI.WorkerInfo> restartedWorkers1) |
getJobStatus, getRestartedWorkers, getWorkerExecuteCount, isJobFaulty, isJobHealthy, registerFaultAcceptor, unRegisterFaultAcceptor
public static void init()
public static void setJobStatus(JobProgress.JobStatus jobStatus1)
public static void increaseWorkerExecuteCount()
public static void setRestartedWorkers(java.util.Collection<JobMasterAPI.WorkerInfo> restartedWorkers1)
public static void faultOccurred(int wID)