public class TezVertexStats extends JobStats
JobStats.JobState
ALIAS, ALIAS_LOCATION, conf, FAILURE_HEADER, FEATURE, hdfsBytesRead, hdfsBytesWritten, inputs, outputs, state, SUCCESS_HEADER
Constructor and Description |
---|
TezVertexStats(String name,
PigStats.JobGraph plan,
boolean isMapOpts) |
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
void |
accumulateStats(org.apache.tez.dag.api.client.VertexStatus status,
int parallelism) |
void |
addInputStatistics() |
void |
addOutputStatistics() |
long |
getAvgMapTime()
Deprecated.
|
long |
getAvgREduceTime()
Deprecated.
|
Map<String,Map<String,Long>> |
getCounters() |
String |
getDisplayString() |
org.apache.hadoop.mapred.Counters |
getHadoopCounters()
Deprecated.
|
String |
getJobId() |
long |
getMapInputRecords()
Deprecated.
|
long |
getMapOutputRecords()
Deprecated.
|
long |
getMaxMapTime()
Deprecated.
|
long |
getMaxReduceTime()
Deprecated.
|
long |
getMinMapTime()
Deprecated.
|
long |
getMinReduceTime()
Deprecated.
|
Map<String,Long> |
getMultiInputCounters()
Deprecated.
|
Map<String,Long> |
getMultiStoreCounters()
Deprecated.
|
int |
getNumberMaps()
Deprecated.
|
int |
getNumberReduces()
Deprecated.
|
int |
getParallelism() |
long |
getProactiveSpillCountObjects() |
long |
getProactiveSpillCountRecs() |
long |
getReduceInputRecords()
Deprecated.
|
long |
getReduceOutputRecords()
Deprecated.
|
long |
getSMMSpillCount() |
boolean |
hasLoadOrStore() |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
calculateMedianValue, getAlias, getAliasLocation, getBytesWritten, getErrorMessage, getException, getFeature, getHdfsBytesRead, getHdfsBytesWritten, getInputs, getOutputs, getOutputSize, getRecordWrittern, getState, isEqual, isIndexer, isSampler, isSuccessful, setBackendException, setErrorMsg, setSuccessful
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public TezVertexStats(String name, PigStats.JobGraph plan, boolean isMapOpts)
public void accept(PlanVisitor v) throws FrontendException
Operator
accept
in class JobStats
v
- Visitor to accept.FrontendException
public String getDisplayString()
getDisplayString
in class JobStats
public void setConf(org.apache.hadoop.conf.Configuration conf)
public boolean hasLoadOrStore()
public void accumulateStats(org.apache.tez.dag.api.client.VertexStatus status, int parallelism)
public int getParallelism()
public void addInputStatistics()
public void addOutputStatistics()
@Deprecated public int getNumberMaps()
getNumberMaps
in class JobStats
@Deprecated public int getNumberReduces()
getNumberReduces
in class JobStats
@Deprecated public long getMaxMapTime()
getMaxMapTime
in class JobStats
@Deprecated public long getMinMapTime()
getMinMapTime
in class JobStats
@Deprecated public long getAvgMapTime()
getAvgMapTime
in class JobStats
@Deprecated public long getMaxReduceTime()
getMaxReduceTime
in class JobStats
@Deprecated public long getMinReduceTime()
getMinReduceTime
in class JobStats
@Deprecated public long getAvgREduceTime()
getAvgREduceTime
in class JobStats
@Deprecated public long getMapInputRecords()
getMapInputRecords
in class JobStats
@Deprecated public long getMapOutputRecords()
getMapOutputRecords
in class JobStats
@Deprecated public long getReduceInputRecords()
getReduceInputRecords
in class JobStats
@Deprecated 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
@Deprecated public org.apache.hadoop.mapred.Counters getHadoopCounters()
getHadoopCounters
in class JobStats
@Deprecated public Map<String,Long> getMultiStoreCounters()
getMultiStoreCounters
in class JobStats
@Deprecated public Map<String,Long> getMultiInputCounters()
getMultiInputCounters
in class JobStats
Copyright © 2007-2017 The Apache Software Foundation