org.apache.pig.tools.pigstats

Class EmptyPigStats

java.lang.Object

org.apache.pig.tools.pigstats.PigStats

org.apache.pig.tools.pigstats.EmptyPigStats

public class EmptyPigStats
extends PigStats

EmptyPigStats encapsulates dummy statistics of a fetch task, since during a fetch no MR jobs are executed

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
EmptyPigStats()
EmptyPigStats(PigContext pigContext, POStore poStore)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.List<java.lang.String>	getAllErrorMessages()
java.util.Map<java.lang.String,java.util.List<PigStats>>	getAllStats()
long	getBytesWritten() Returns the total bytes written to user specified HDFS locations of this script.
java.util.List<InputStats>	getInputStats()
org.apache.hadoop.mapred.JobClient	getJobClient()
PigStats.JobGraph	getJobGraph() Returns the DAG of jobs spawned by the script
long	getNumberBytes(java.lang.String location) Returns the number of bytes for the given output location, -1 for invalid location or name.
int	getNumberFailedJobs()
int	getNumberJobs() Returns the number of jobs for this script
long	getNumberRecords(java.lang.String location) Returns the number of records for the given output location, -1 for invalid location or name.
int	getNumberSuccessfulJobs()
java.lang.String	getOutputAlias(java.lang.String location) Returns the alias associated with this output location
java.util.List<java.lang.String>	getOutputLocations() Returns the list of output locations in the script
java.util.List<java.lang.String>	getOutputNames() Returns the list of output names in the script
java.util.List<OutputStats>	getOutputStats()
long	getProactiveSpillCountObjects() Returns the total number of bags that spilled proactively
long	getProactiveSpillCountRecords() Returns the total number of records that spilled proactively
long	getRecordWritten() Returns the total number of records in user specified output locations of this script.
long	getSMMSpillCount() Returns the total spill counts from SpillableMemoryManager.
boolean	isEmbedded()
OutputStats	result(java.lang.String alias)
void	setBackendException(java.lang.String jobId, java.lang.Exception e)
void	start()
void	stop()

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

get, getDuration, getErrorCode, getErrorMessage, getErrorThrowable, getFeatures, getFileName, getHadoopVersion, getPigContext, getPigProperties, getPigVersion, getReturnCode, getScriptId, isSuccessful, setErrorCode, setErrorMessage, setErrorThrowable, setReturnCode, start

Methods inherited from class java.lang.Object

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

Constructor Detail

EmptyPigStats

public EmptyPigStats()

EmptyPigStats

public EmptyPigStats(PigContext pigContext,
             POStore poStore)

Method Detail

getJobClient

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

Specified by:

getJobClient in class PigStats

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in class PigStats

getAllStats

public java.util.Map<java.lang.String,java.util.List<PigStats>> getAllStats()

Specified by:

getAllStats in class PigStats

getAllErrorMessages

public java.util.List<java.lang.String> getAllErrorMessages()

Specified by:

getAllErrorMessages in class PigStats

getJobGraph

public PigStats.JobGraph getJobGraph()

Description copied from class: PigStats

Returns the DAG of jobs spawned by the script

Overrides:

getJobGraph in class PigStats

getOutputLocations

public java.util.List<java.lang.String> getOutputLocations()

Description copied from class: PigStats

Returns the list of output locations in the script

Overrides:

getOutputLocations in class PigStats

getOutputNames

public java.util.List<java.lang.String> getOutputNames()

Description copied from class: PigStats

Returns the list of output names in the script

Overrides:

getOutputNames in class PigStats

getNumberBytes

public long getNumberBytes(java.lang.String location)

Description copied from class: PigStats

Returns the number of bytes for the given output location, -1 for invalid location or name.

Overrides:

getNumberBytes in class PigStats

getNumberRecords

public long getNumberRecords(java.lang.String location)

Description copied from class: PigStats

Returns the number of records for the given output location, -1 for invalid location or name.

Overrides:

getNumberRecords in class PigStats

getOutputAlias

public java.lang.String getOutputAlias(java.lang.String location)

Description copied from class: PigStats

Returns the alias associated with this output location

Overrides:

getOutputAlias 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

getProactiveSpillCountRecords

public long getProactiveSpillCountRecords()

Description copied from class: PigStats

Returns the total number of records that spilled proactively

Specified by:

getProactiveSpillCountRecords 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

getBytesWritten

public long getBytesWritten()

Description copied from class: PigStats

Returns the total bytes written to user specified HDFS locations of this script.

Overrides:

getBytesWritten in class PigStats

getRecordWritten

public long getRecordWritten()

Description copied from class: PigStats

Returns the total number of records in user specified output locations of this script.

Overrides:

getRecordWritten in class PigStats

getNumberJobs

public int getNumberJobs()

Description copied from class: PigStats

Returns the number of jobs for this script

Overrides:

getNumberJobs in class PigStats

getOutputStats

public java.util.List<OutputStats> getOutputStats()

Overrides:

getOutputStats in class PigStats

result

public OutputStats result(java.lang.String alias)

Overrides:

result in class PigStats

getInputStats

public java.util.List<InputStats> getInputStats()

Overrides:

getInputStats in class PigStats

setBackendException

public void setBackendException(java.lang.String jobId,
                       java.lang.Exception e)

Overrides:

setBackendException in class PigStats

start

public void start()

Overrides:

start in class PigStats

stop

public void stop()

Overrides:

stop in class PigStats

getNumberSuccessfulJobs

public int getNumberSuccessfulJobs()

Overrides:

getNumberSuccessfulJobs in class PigStats

getNumberFailedJobs

public int getNumberFailedJobs()

Overrides:

getNumberFailedJobs in class PigStats