org.apache.pig.tools.pigstats
Class EmptyPigStats

java.lang.Object
  extended by org.apache.pig.tools.pigstats.PigStats
      extended by 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
EmptyPigStats()
           
EmptyPigStats(PigContext pigContext, POStore poStore)
           
 
Method Summary
 List<String> getAllErrorMessages()
           
 Map<String,List<PigStats>> getAllStats()
           
 long getBytesWritten()
          Returns the total bytes written to user specified HDFS locations of this script.
 List<InputStats> getInputStats()
           
 org.apache.hadoop.mapred.JobClient getJobClient()
           
 PigStats.JobGraph getJobGraph()
          Returns the DAG of jobs spawned by the script
 long getNumberBytes(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(String location)
          Returns the number of records for the given output location, -1 for invalid location or name.
 int getNumberSuccessfulJobs()
           
 String getOutputAlias(String location)
          Returns the alias associated with this output location
 List<String> getOutputLocations()
          Returns the list of output locations in the script
 List<String> getOutputNames()
          Returns the list of output names in the script
 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(String alias)
           
 void setBackendException(String jobId, 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 Map<String,List<PigStats>> getAllStats()
Specified by:
getAllStats in class PigStats

getAllErrorMessages

public List<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 List<String> getOutputLocations()
Description copied from class: PigStats
Returns the list of output locations in the script

Overrides:
getOutputLocations in class PigStats

getOutputNames

public List<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(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(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 String getOutputAlias(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 List<OutputStats> getOutputStats()
Overrides:
getOutputStats in class PigStats

result

public OutputStats result(String alias)
Overrides:
result in class PigStats

getInputStats

public List<InputStats> getInputStats()
Overrides:
getInputStats in class PigStats

setBackendException

public void setBackendException(String jobId,
                                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


Copyright © 2007-2012 The Apache Software Foundation