public class JobProgress
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
JobProgress.JobStatus
Job state
|
Modifier and Type | Field and Description |
---|---|
protected static java.util.List<FaultAcceptable> |
faultAcceptors
Keep track of the components that have the ability to deal with faults
|
protected static JobProgress.JobStatus |
jobStatus |
protected static java.util.List<JobMasterAPI.WorkerInfo> |
restartedWorkers |
protected static int |
workerExecuteCount |
Constructor and Description |
---|
JobProgress() |
Modifier and Type | Method and Description |
---|---|
static JobProgress.JobStatus |
getJobStatus() |
static java.util.List<JobMasterAPI.WorkerInfo> |
getRestartedWorkers() |
static int |
getWorkerExecuteCount() |
static boolean |
isJobFaulty() |
static boolean |
isJobHealthy() |
static void |
registerFaultAcceptor(FaultAcceptable faultAcceptable) |
static void |
unRegisterFaultAcceptor(FaultAcceptable faultAcceptable) |
protected static JobProgress.JobStatus jobStatus
protected static int workerExecuteCount
protected static java.util.List<JobMasterAPI.WorkerInfo> restartedWorkers
protected static java.util.List<FaultAcceptable> faultAcceptors
public static JobProgress.JobStatus getJobStatus()
public static boolean isJobHealthy()
public static boolean isJobFaulty()
public static int getWorkerExecuteCount()
public static java.util.List<JobMasterAPI.WorkerInfo> getRestartedWorkers()
public static void registerFaultAcceptor(FaultAcceptable faultAcceptable)
public static void unRegisterFaultAcceptor(FaultAcceptable faultAcceptable)