@InterfaceAudience.Public @InterfaceStability.Evolving public abstract class PigTezProgressNotificationListener extends Object implements PigProgressNotificationListener
PigRunner
.Constructor and Description |
---|
PigTezProgressNotificationListener() |
Modifier and Type | Method and Description |
---|---|
abstract void |
dagCompletedNotification(String scriptId,
String dagId,
boolean success,
TezDAGStats tezDAGStats)
Invoked just after the Tez DAGs is completed (successful or failed).
|
abstract void |
dagLaunchNotification(String scriptId,
String dagId,
OperatorPlan<?> dagPlan,
int numVerticesToLaunch)
Invoked just before launching a Tez DAG spawned by the script.
|
abstract void |
dagProgressNotification(String scriptId,
String dagId,
int numVerticesCompleted,
int progress)
Invoked to update the execution progress.
|
abstract void |
dagStartedNotification(String scriptId,
String dagId,
String assignedApplicationId)
Invoked after a Tez DAG is started.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initialPlanNotification, jobFailedNotification, jobFinishedNotification, jobsSubmittedNotification, jobStartedNotification, launchCompletedNotification, launchStartedNotification, outputCompletedNotification, progressUpdatedNotification
public abstract void dagLaunchNotification(String scriptId, String dagId, OperatorPlan<?> dagPlan, int numVerticesToLaunch)
scriptId
- the unique id of the scriptdagId
- the unique name of the Tez DAGdagPlan
- the OperatorPlan that is to be executednumVerticesToLaunch
- the total number of vertices spawned by the Tez DAGpublic abstract void dagStartedNotification(String scriptId, String dagId, String assignedApplicationId)
scriptId
- the unique id of the scriptdagId
- the unique name of the Tez DAGassignedApplicationId
- the YARN application id for the Tez DAG. More than one Tez DAG
can share same application ID if session reuse is turned on.
Session reuse is turned on by defaultpublic abstract void dagProgressNotification(String scriptId, String dagId, int numVerticesCompleted, int progress)
scriptId
- the unique id of the scriptdagId
- the unique name of the Tez DAGnumVerticesCompleted
- the number of vertices completed so farprogress
- the percentage of the execution progress based on total number of tasks of all verticespublic abstract void dagCompletedNotification(String scriptId, String dagId, boolean success, TezDAGStats tezDAGStats)
scriptId
- the unique id of the scriptdagId
- the unique name of the Tez DAGsuccess
- true if the Tez DAG was successful, false otherwisetezDAGStats
- the stats information for the DAGCopyright © 2007-2017 The Apache Software Foundation