org.apache.pig.tools.pigstats.tez

Class TezDAGStats

java.lang.Object

org.apache.pig.newplan.Operator

org.apache.pig.tools.pigstats.JobStats

org.apache.pig.tools.pigstats.tez.TezDAGStats

All Implemented Interfaces:

java.io.Serializable

public class TezDAGStats
extends JobStats

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.tools.pigstats.JobStats

JobStats.JobState

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DAG_COUNTER_GROUP
static java.lang.String	FAILURE_HEADER
static java.lang.String	FS_COUNTER_GROUP
static java.lang.String	PIG_COUNTER_GROUP
static java.lang.String	SUCCESS_HEADER
static java.lang.String	TASK_COUNTER_GROUP

Fields inherited from class org.apache.pig.tools.pigstats.JobStats

ALIAS, ALIAS_LOCATION, conf, FEATURE, hdfsBytesRead, hdfsBytesWritten, inputs, outputs, state

Fields inherited from class org.apache.pig.newplan.Operator

annotations, hashPrime, location, name, plan

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TezDAGStats(java.lang.String name, PigStats.JobGraph plan, java.util.Map<java.lang.String,TezVertexStats> tezVertexStatsMap, java.lang.StringBuilder tezDAGPlan)

Method Summary

Modifier and Type	Method and Description
void	accept(PlanVisitor v) Accept a visitor at this node in the graph.
void	accumulateStats(TezJob tezJob) Updates the statistics after a DAG is finished.
long	getAvgMapTime() Deprecated.
long	getAvgREduceTime() Deprecated.
java.lang.String	getDisplayString()
org.apache.hadoop.mapred.Counters	getHadoopCounters() Deprecated.
java.lang.String	getJobId()
long	getMapInputRecords() Deprecated.
long	getMapOutputRecords() Deprecated.
long	getMaxMapTime() Deprecated.
long	getMaxReduceTime() Deprecated.
long	getMinMapTime() Deprecated.
long	getMinReduceTime() Deprecated.
java.util.Map<java.lang.String,java.lang.Long>	getMultiInputCounters() Deprecated.
java.util.Map<java.lang.String,java.lang.Long>	getMultiStoreCounters() Deprecated.
int	getNumberMaps() Deprecated.
int	getNumberReduces() Deprecated.
long	getProactiveSpillCountObjects()
long	getProactiveSpillCountRecs()
long	getReduceInputRecords() Deprecated.
long	getReduceOutputRecords() Deprecated.
long	getSMMSpillCount()
TezVertexStats	getVertexStats(java.lang.String vertexName)
void	setJobId(java.lang.String appId)

Methods inherited from class org.apache.pig.tools.pigstats.JobStats

calculateMedianValue, getAlias, getAliasLocation, getBytesWritten, getErrorMessage, getException, getFeature, getHdfsBytesRead, getHdfsBytesWritten, getInputs, getOutputs, getOutputSize, getRecordWrittern, getState, isEqual, isIndexer, isSampler, isSuccessful, setBackendException, setConf, setErrorMsg, setSuccessful

Methods inherited from class org.apache.pig.newplan.Operator

annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DAG_COUNTER_GROUP

public static final java.lang.String DAG_COUNTER_GROUP

FS_COUNTER_GROUP

public static final java.lang.String FS_COUNTER_GROUP

TASK_COUNTER_GROUP

public static final java.lang.String TASK_COUNTER_GROUP

PIG_COUNTER_GROUP

public static final java.lang.String PIG_COUNTER_GROUP

SUCCESS_HEADER

public static final java.lang.String SUCCESS_HEADER

FAILURE_HEADER

public static final java.lang.String FAILURE_HEADER

Constructor Detail

TezDAGStats

protected TezDAGStats(java.lang.String name,
                      PigStats.JobGraph plan,
                      java.util.Map<java.lang.String,TezVertexStats> tezVertexStatsMap,
                      java.lang.StringBuilder tezDAGPlan)

Method Detail

getVertexStats

public TezVertexStats getVertexStats(java.lang.String vertexName)

accumulateStats

public void accumulateStats(TezJob tezJob)
                     throws java.io.IOException

Updates the statistics after a DAG is finished.

Throws:

java.io.IOException

getJobId

public java.lang.String getJobId()

Specified by:

getJobId in class JobStats

setJobId

public void setJobId(java.lang.String appId)

accept

public void accept(PlanVisitor v)
            throws FrontendException

Description copied from class: Operator

Accept a visitor at this node in the graph.

Specified by:

accept in class JobStats

Parameters:

v - Visitor to accept.

Throws:

FrontendException

getDisplayString

public java.lang.String getDisplayString()

Specified by:

getDisplayString in class JobStats

getNumberMaps

@Deprecated
public int getNumberMaps()

Deprecated.

Specified by:

getNumberMaps in class JobStats

getNumberReduces

@Deprecated
public int getNumberReduces()

Deprecated.

Specified by:

getNumberReduces in class JobStats

getMaxMapTime

@Deprecated
public long getMaxMapTime()

Deprecated.

Specified by:

getMaxMapTime in class JobStats

getMinMapTime

@Deprecated
public long getMinMapTime()

Deprecated.

Specified by:

getMinMapTime in class JobStats

getAvgMapTime

@Deprecated
public long getAvgMapTime()

Deprecated.

Specified by:

getAvgMapTime in class JobStats

getMaxReduceTime

@Deprecated
public long getMaxReduceTime()

Deprecated.

Specified by:

getMaxReduceTime in class JobStats

getMinReduceTime

@Deprecated
public long getMinReduceTime()

Deprecated.

Specified by:

getMinReduceTime in class JobStats

getAvgREduceTime

@Deprecated
public long getAvgREduceTime()

Deprecated.

Specified by:

getAvgREduceTime in class JobStats

getMapInputRecords

@Deprecated
public long getMapInputRecords()

Deprecated.

Specified by:

getMapInputRecords in class JobStats

getMapOutputRecords

@Deprecated
public long getMapOutputRecords()

Deprecated.

Specified by:

getMapOutputRecords in class JobStats

getReduceInputRecords

@Deprecated
public long getReduceInputRecords()

Deprecated.

Specified by:

getReduceInputRecords in class JobStats

getReduceOutputRecords

@Deprecated
public long getReduceOutputRecords()

Deprecated.

Specified by:

getReduceOutputRecords in class JobStats

getSMMSpillCount

public long getSMMSpillCount()

Specified by:

getSMMSpillCount in class JobStats

getProactiveSpillCountObjects

public long getProactiveSpillCountObjects()

Specified by:

getProactiveSpillCountObjects in class JobStats

getProactiveSpillCountRecs

public long getProactiveSpillCountRecs()

Specified by:

getProactiveSpillCountRecs in class JobStats

getHadoopCounters

@Deprecated
public org.apache.hadoop.mapred.Counters getHadoopCounters()

Deprecated.

Specified by:

getHadoopCounters in class JobStats

getMultiStoreCounters

@Deprecated
public java.util.Map<java.lang.String,java.lang.Long> getMultiStoreCounters()

Deprecated.

Specified by:

getMultiStoreCounters in class JobStats

getMultiInputCounters

@Deprecated
public java.util.Map<java.lang.String,java.lang.Long> getMultiInputCounters()

Deprecated.

Specified by:

getMultiInputCounters in class JobStats