public class TezPigScriptStats extends PigStats
PigStats.JobGraph, PigStats.JobGraphPrinter
aliasOuputMap, DATE_FORMAT, endTime, errorCode, errorMessage, errorThrowable, jobPlan, pigContext, returnCode, startTime, userId
Constructor and Description |
---|
TezPigScriptStats(PigContext pigContext) |
Modifier and Type | Method and Description |
---|---|
void |
accumulateStats(TezJob tezJob)
Updates the statistics after a DAG is finished.
|
TezDAGStats |
addTezJobStatsForNative(String dagName,
NativeTezOper tezOper,
boolean success) |
void |
finish() |
List<String> |
getAllErrorMessages() |
Map<String,List<PigStats>> |
getAllStats() |
String |
getDisplayString()
Returns the display message in pig grunt
|
org.apache.hadoop.mapred.JobClient |
getJobClient() |
long |
getProactiveSpillCountObjects()
Returns the total number of bags that spilled proactively
|
long |
getProactiveSpillCountRecords()
Returns the total number of records that spilled proactively
|
long |
getSMMSpillCount()
Returns the total spill counts from
SpillableMemoryManager . |
TezVertexStats |
getVertexStats(String dagName,
String vertexName) |
void |
initialize(TezPlanContainer tezPlanContainer) |
boolean |
isEmbedded() |
get, getBytesWritten, getDuration, getErrorCode, getErrorMessage, getErrorThrowable, getFeatures, getFileName, getHadoopVersion, getInputStats, getJobGraph, getNumberBytes, getNumberFailedJobs, getNumberJobs, getNumberRecords, getNumberSuccessfulJobs, getOutputAlias, getOutputLocations, getOutputNames, getOutputStats, getPigContext, getPigProperties, getPigVersion, getRecordWritten, getReturnCode, getScript, getScriptId, isSuccessful, result, setBackendException, setErrorCode, setErrorMessage, setErrorThrowable, setReturnCode, start, start, stop
public TezPigScriptStats(PigContext pigContext)
public void initialize(TezPlanContainer tezPlanContainer)
public void finish()
public String getDisplayString()
PigStats
getDisplayString
in class PigStats
public void accumulateStats(TezJob tezJob) throws IOException
IOException
public TezDAGStats addTezJobStatsForNative(String dagName, NativeTezOper tezOper, boolean success)
public TezVertexStats getVertexStats(String dagName, String vertexName)
public boolean isEmbedded()
isEmbedded
in class PigStats
public org.apache.hadoop.mapred.JobClient getJobClient()
getJobClient
in class PigStats
public Map<String,List<PigStats>> getAllStats()
getAllStats
in class PigStats
public List<String> getAllErrorMessages()
getAllErrorMessages
in class PigStats
public long getSMMSpillCount()
PigStats
SpillableMemoryManager
.getSMMSpillCount
in class PigStats
public long getProactiveSpillCountObjects()
PigStats
getProactiveSpillCountObjects
in class PigStats
public long getProactiveSpillCountRecords()
PigStats
getProactiveSpillCountRecords
in class PigStats
Copyright © 2007-2017 The Apache Software Foundation