@InterfaceAudience.Public @InterfaceStability.Evolving public final class MRJobStats extends JobStats
JobStats.JobState
Modifier and Type | Field and Description |
---|---|
static String |
FAILURE_HEADER |
static String |
SUCCESS_HEADER |
ALIAS, ALIAS_LOCATION, conf, FEATURE, hdfsBytesRead, hdfsBytesWritten, inputs, outputs, state
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
String |
getAlias() |
String |
getAliasLocation() |
long |
getAvgMapTime() |
long |
getAvgREduceTime() |
static org.apache.hadoop.mapred.Counters |
getCounters(org.apache.hadoop.mapred.jobcontrol.Job job) |
String |
getDisplayString() |
String |
getFeature() |
org.apache.hadoop.mapred.Counters |
getHadoopCounters() |
String |
getJobId() |
long |
getMapInputRecords() |
long |
getMapOutputRecords() |
long |
getMaxMapTime() |
long |
getMaxReduceTime() |
long |
getMinMapTime() |
long |
getMinReduceTime() |
Map<String,Long> |
getMultiInputCounters() |
Map<String,Long> |
getMultiStoreCounters() |
int |
getNumberMaps() |
int |
getNumberReduces() |
long |
getProactiveSpillCountObjects() |
long |
getProactiveSpillCountRecs() |
long |
getReduceInputRecords() |
long |
getReduceOutputRecords() |
long |
getSMMSpillCount() |
static Iterator<org.apache.hadoop.mapreduce.TaskReport> |
getTaskReports(org.apache.hadoop.mapred.jobcontrol.Job job,
org.apache.hadoop.mapreduce.TaskType type) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
calculateMedianValue, getBytesWritten, getErrorMessage, getException, getHdfsBytesRead, getHdfsBytesWritten, getInputs, getOutputs, getOutputSize, getRecordWrittern, getState, isEqual, isIndexer, isSampler, isSuccessful, setBackendException, setErrorMsg, setSuccessful
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public static final String SUCCESS_HEADER
public static final String FAILURE_HEADER
public int getNumberMaps()
getNumberMaps
in class JobStats
public int getNumberReduces()
getNumberReduces
in class JobStats
public long getMaxMapTime()
getMaxMapTime
in class JobStats
public long getMinMapTime()
getMinMapTime
in class JobStats
public long getAvgMapTime()
getAvgMapTime
in class JobStats
public long getMaxReduceTime()
getMaxReduceTime
in class JobStats
public long getMinReduceTime()
getMinReduceTime
in class JobStats
public long getAvgREduceTime()
getAvgREduceTime
in class JobStats
public long getMapInputRecords()
getMapInputRecords
in class JobStats
public long getMapOutputRecords()
getMapOutputRecords
in class JobStats
public long getReduceInputRecords()
getReduceInputRecords
in class JobStats
public long getReduceOutputRecords()
getReduceOutputRecords
in class JobStats
public long getSMMSpillCount()
getSMMSpillCount
in class JobStats
public long getProactiveSpillCountObjects()
getProactiveSpillCountObjects
in class JobStats
public long getProactiveSpillCountRecs()
getProactiveSpillCountRecs
in class JobStats
public org.apache.hadoop.mapred.Counters getHadoopCounters()
getHadoopCounters
in class JobStats
public Map<String,Long> getMultiStoreCounters()
getMultiStoreCounters
in class JobStats
public Map<String,Long> getMultiInputCounters()
getMultiInputCounters
in class JobStats
public String getAliasLocation()
getAliasLocation
in class JobStats
public String getFeature()
getFeature
in class JobStats
public void accept(PlanVisitor v) throws FrontendException
Operator
accept
in class JobStats
v
- Visitor to accept.FrontendException
public void setConf(org.apache.hadoop.conf.Configuration conf)
public String getDisplayString()
getDisplayString
in class JobStats
public static Iterator<org.apache.hadoop.mapreduce.TaskReport> getTaskReports(org.apache.hadoop.mapred.jobcontrol.Job job, org.apache.hadoop.mapreduce.TaskType type) throws IOException
IOException
public static org.apache.hadoop.mapred.Counters getCounters(org.apache.hadoop.mapred.jobcontrol.Job job) throws IOException
IOException
Copyright © 2007-2017 The Apache Software Foundation