| Package | Description |
|---|---|
| org.apache.pig.tools.pigstats |
| Modifier and Type | Method and Description |
|---|---|
static JobStats |
PigStatsUtil.addJobStats(org.apache.hadoop.mapred.jobcontrol.Job job)
Add stats for a new Job, which doesn't yet need to be completed.
|
static JobStats |
PigStatsUtil.addNativeJobStats(PigStats ps,
NativeMapReduceOper mr,
boolean success) |
static JobStats |
PigStatsUtil.addNativeJobStats(PigStats ps,
NativeMapReduceOper mr,
boolean success,
Exception e) |
| Modifier and Type | Method and Description |
|---|---|
List<JobStats> |
PigStats.JobGraph.getFailedJobs() |
List<JobStats> |
PigStats.JobGraph.getJobList()
Returns a List representation of the Job graph.
|
List<JobStats> |
PigStats.JobGraph.getSuccessfulJobs() |
Iterator<JobStats> |
PigStats.JobGraph.iterator() |
| Modifier and Type | Method and Description |
|---|---|
void |
ScriptState.emitJobFailedNotification(JobStats jobStats) |
void |
ScriptState.emitjobFinishedNotification(JobStats jobStats) |
void |
PigProgressNotificationListener.jobFailedNotification(String scriptId,
JobStats jobStats)
Invoked when a MR job fails.
|
void |
PigProgressNotificationListener.jobFinishedNotification(String scriptId,
JobStats jobStats)
Invoked just after a MR job is completed successfully.
|
Copyright © 2007-2012 The Apache Software Foundation