org.apache.pig.tools.pigstats.tez

Class TezVertexStats

java.lang.Object

org.apache.pig.newplan.Operator

org.apache.pig.tools.pigstats.JobStats

org.apache.pig.tools.pigstats.tez.TezVertexStats

All Implemented Interfaces:

java.io.Serializable

public class TezVertexStats
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 inherited from class org.apache.pig.tools.pigstats.JobStats

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

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

annotations, hashPrime, location, name, plan

Constructor Summary

Constructors

Constructor and Description
TezVertexStats(java.lang.String name, PigStats.JobGraph plan, boolean isMapOpts)

Method Summary

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.
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>>	getCounters()
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.
int	getParallelism()
long	getProactiveSpillCountObjects()
long	getProactiveSpillCountRecs()
long	getReduceInputRecords() Deprecated.
long	getReduceOutputRecords() Deprecated.
long	getSMMSpillCount()
boolean	hasLoadOrStore()
void	setConf(org.apache.hadoop.conf.Configuration conf)

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, 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

Constructor Detail

TezVertexStats

public TezVertexStats(java.lang.String name,
                      PigStats.JobGraph plan,
                      boolean isMapOpts)

Method Detail

getJobId

public java.lang.String getJobId()

Specified by:

getJobId in class JobStats

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

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Overrides:

setConf in class JobStats

hasLoadOrStore

public boolean hasLoadOrStore()

accumulateStats

public void accumulateStats(org.apache.tez.dag.api.client.VertexStatus status,
                            int parallelism)

getCounters

public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> getCounters()

getParallelism

public int getParallelism()

addInputStatistics

public void addInputStatistics()

addOutputStatistics

public void addOutputStatistics()

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