org.apache.pig.tools.pigstats.mapreduce

Class SimplePigStats

java.lang.Object

org.apache.pig.tools.pigstats.PigStats

org.apache.pig.tools.pigstats.mapreduce.SimplePigStats

public final class SimplePigStats
extends PigStats

SimplePigStats encapsulates the statistics collected from a running script. It includes status of the execution, the DAG of its MR jobs, as well as information about outputs and inputs of the script.

Nested Class Summary

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

PigStats.JobGraph, PigStats.JobGraphPrinter

Field Summary

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

aliasOuputMap, DATE_FORMAT, endTime, errorCode, errorMessage, errorThrowable, jobPlan, pigContext, returnCode, startTime, userId

Constructor Summary

Constructors

Constructor and Description
SimplePigStats()

Method Summary

Modifier and Type	Method and Description
List<String>	getAllErrorMessages()
Map<String,List<PigStats>>	getAllStats()
String	getDisplayString() Returns the display message in pig grunt
org.apache.hadoop.mapred.JobClient	getJobClient() Deprecated.
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.
boolean	isEmbedded()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SimplePigStats

public SimplePigStats()

Method Detail

getAllErrorMessages

public List<String> getAllErrorMessages()

Specified by:

getAllErrorMessages in class PigStats

getAllStats

public Map<String,List<PigStats>> getAllStats()

Specified by:

getAllStats in class PigStats

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in class PigStats

getSMMSpillCount

public long getSMMSpillCount()

Description copied from class: PigStats

Returns the total spill counts from SpillableMemoryManager.

Specified by:

getSMMSpillCount in class PigStats

getProactiveSpillCountObjects

public long getProactiveSpillCountObjects()

Description copied from class: PigStats

Returns the total number of bags that spilled proactively

Specified by:

getProactiveSpillCountObjects in class PigStats

getProactiveSpillCountRecords

public long getProactiveSpillCountRecords()

Description copied from class: PigStats

Returns the total number of records that spilled proactively

Specified by:

getProactiveSpillCountRecords in class PigStats

getJobClient

@Deprecated
public org.apache.hadoop.mapred.JobClient getJobClient()

Deprecated.

Specified by:

getJobClient in class PigStats

getDisplayString

public String getDisplayString()

Description copied from class: PigStats

Returns the display message in pig grunt

Specified by:

getDisplayString in class PigStats