public class FailureMonitor
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.util.Map |
index2job
Id to a Job.
|
protected static java.util.Map<java.lang.Integer,FailureRecord> |
jobid2record
JobID to a Failure Record.
|
protected static java.util.List<FailureRecord> |
recordList
All the record list.
|
protected static java.util.Map<java.lang.Integer,java.util.ArrayList<FailureRecord>> |
type2record
Type to a Failure Record.
|
protected static java.util.Map<java.lang.Integer,java.util.ArrayList<FailureRecord>> |
vm2record
VM ID to a Failure Record.
|
| Constructor and Description |
|---|
FailureMonitor() |
| Modifier and Type | Method and Description |
|---|---|
static double |
analyze(int workflowId,
int type)
Update the detected task failure rate based on record lists
|
static int |
getClusteringFactor(FailureRecord record)
Gets the clustering factor
|
protected static double |
getK(double d,
double a,
double t)
Gets the optimal clustering factor based on analysis
|
static void |
init()
Initialize a FailureMonitor object.
|
static void |
postFailureRecord(FailureRecord record)
A post from a broker so that we can update record list
|
protected static java.util.Map<java.lang.Integer,java.util.ArrayList<FailureRecord>> vm2record
protected static java.util.Map<java.lang.Integer,java.util.ArrayList<FailureRecord>> type2record
protected static java.util.Map<java.lang.Integer,FailureRecord> jobid2record
protected static java.util.List<FailureRecord> recordList
public static java.util.Map index2job
public static void init()
protected static double getK(double d,
double a,
double t)
d - delaya - task failure rate monitoredt - task runtimepublic static int getClusteringFactor(FailureRecord record)
record, - a requestpublic static void postFailureRecord(FailureRecord record)
record - a failure recordpublic static double analyze(int workflowId,
int type)
workflowId, - doesn't work in this versiontype, - the type of job or vm