public class EmptyPigStats extends PigStats
PigStats.JobGraph, PigStats.JobGraphPrinter
aliasOuputMap, DATE_FORMAT, endTime, errorCode, errorMessage, errorThrowable, jobPlan, pigContext, returnCode, startTime, userId
Constructor and Description |
---|
EmptyPigStats() |
EmptyPigStats(PigContext pigContext,
POStore poStore) |
Modifier and Type | Method and Description |
---|---|
List<String> |
getAllErrorMessages() |
Map<String,List<PigStats>> |
getAllStats() |
long |
getBytesWritten()
Returns the total bytes written to user specified HDFS
locations of this script.
|
String |
getDisplayString()
Returns the display message in pig grunt
|
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() |
get, getDuration, getErrorCode, getErrorMessage, getErrorThrowable, getFeatures, getFileName, getHadoopVersion, getPigContext, getPigProperties, getPigVersion, getReturnCode, getScript, getScriptId, isSuccessful, setErrorCode, setErrorMessage, setErrorThrowable, setReturnCode, start
public EmptyPigStats()
public EmptyPigStats(PigContext pigContext, POStore poStore)
public org.apache.hadoop.mapred.JobClient getJobClient()
getJobClient
in class PigStats
public boolean isEmbedded()
isEmbedded
in class PigStats
public Map<String,List<PigStats>> getAllStats()
getAllStats
in class PigStats
public List<String> getAllErrorMessages()
getAllErrorMessages
in class PigStats
public String getDisplayString()
PigStats
getDisplayString
in class PigStats
public PigStats.JobGraph getJobGraph()
PigStats
getJobGraph
in class PigStats
public List<String> getOutputLocations()
PigStats
getOutputLocations
in class PigStats
public List<String> getOutputNames()
PigStats
getOutputNames
in class PigStats
public long getNumberBytes(String location)
PigStats
getNumberBytes
in class PigStats
public long getNumberRecords(String location)
PigStats
getNumberRecords
in class PigStats
public String getOutputAlias(String location)
PigStats
getOutputAlias
in class PigStats
public long getSMMSpillCount()
PigStats
SpillableMemoryManager
.getSMMSpillCount
in class PigStats
public long getProactiveSpillCountRecords()
PigStats
getProactiveSpillCountRecords
in class PigStats
public long getProactiveSpillCountObjects()
PigStats
getProactiveSpillCountObjects
in class PigStats
public long getBytesWritten()
PigStats
getBytesWritten
in class PigStats
public long getRecordWritten()
PigStats
getRecordWritten
in class PigStats
public int getNumberJobs()
PigStats
getNumberJobs
in class PigStats
public List<OutputStats> getOutputStats()
getOutputStats
in class PigStats
public OutputStats result(String alias)
public List<InputStats> getInputStats()
getInputStats
in class PigStats
public void setBackendException(String jobId, Exception e)
setBackendException
in class PigStats
public int getNumberSuccessfulJobs()
getNumberSuccessfulJobs
in class PigStats
public int getNumberFailedJobs()
getNumberFailedJobs
in class PigStats
Copyright © 2007-2017 The Apache Software Foundation