Package | Description |
---|---|
org.apache.pig.tools.pigstats | |
org.apache.pig.tools.pigstats.mapreduce | |
org.apache.pig.tools.pigstats.spark | |
org.apache.pig.tools.pigstats.tez |
Modifier and Type | Method and Description |
---|---|
java.util.List<JobStats> |
PigStats.JobGraph.getFailedJobs() |
java.util.List<JobStats> |
PigStats.JobGraph.getJobList()
Returns a List representation of the Job graph.
|
java.util.List<JobStats> |
PigStats.JobGraph.getSuccessfulJobs() |
java.util.Iterator<JobStats> |
PigStats.JobGraph.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.emitJobFailedNotification(JobStats jobStats) |
void |
ScriptState.emitjobFinishedNotification(JobStats jobStats) |
void |
PigProgressNotificationListener.jobFailedNotification(java.lang.String scriptId,
JobStats jobStats)
Invoked when a Hadoop job fails.
|
void |
PigProgressNotificationListener.jobFinishedNotification(java.lang.String scriptId,
JobStats jobStats)
Invoked just after a Hadoop job (or Tez DAG) is completed successfully.
|
void |
PigStats.JobGraphPrinter.visit(JobStats op) |
Modifier and Type | Class and Description |
---|---|
class |
MRJobStats
This class encapsulates the runtime statistics of a MapReduce job.
|
Modifier and Type | Method and Description |
---|---|
static JobStats |
MRPigStatsUtil.addJobStats(org.apache.hadoop.mapred.jobcontrol.Job job)
Add stats for a new Job, which doesn't yet need to be completed.
|
Modifier and Type | Class and Description |
---|---|
class |
Spark1JobStats |
class |
Spark2JobStats |
class |
SparkJobStats |
Modifier and Type | Class and Description |
---|---|
class |
TezDAGStats |
class |
TezVertexStats |
Copyright © 2007-2017 The Apache Software Foundation