org.apache.tez.dag.api.client

Class MRDAGClient

java.lang.Object

org.apache.tez.dag.api.client.DAGClient

org.apache.tez.dag.api.client.MRDAGClient

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
public class MRDAGClient
extends org.apache.tez.dag.api.client.DAGClient

Constructor Summary

Constructors

Constructor and Description
MRDAGClient(org.apache.tez.dag.api.client.DAGClient dagClient)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReport()
protected org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReportInternal()
org.apache.tez.dag.api.client.DAGStatus	getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
org.apache.tez.dag.api.client.DAGStatus	getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions, long timeout)
String	getExecutionContext()
org.apache.tez.dag.api.client.VertexStatus	getVertexStatus(String vertexName, Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
void	tryKillDAG()
org.apache.tez.dag.api.client.DAGStatus	waitForCompletion()
org.apache.tez.dag.api.client.DAGStatus	waitForCompletionWithStatusUpdates(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusGetOpts)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MRDAGClient

public MRDAGClient(org.apache.tez.dag.api.client.DAGClient dagClient)

Method Detail

getExecutionContext

public String getExecutionContext()

Specified by:

getExecutionContext in class org.apache.tez.dag.api.client.DAGClient

getApplicationReportInternal

protected org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReportInternal()

Specified by:

getApplicationReportInternal in class org.apache.tez.dag.api.client.DAGClient

getApplicationReport

public org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReport()

getDAGStatus

public org.apache.tez.dag.api.client.DAGStatus getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
                                                     throws IOException,
                                                            org.apache.tez.dag.api.TezException

Specified by:

getDAGStatus in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException

getVertexStatus

public org.apache.tez.dag.api.client.VertexStatus getVertexStatus(String vertexName,
                                                         Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
                                                           throws IOException,
                                                                  org.apache.tez.dag.api.TezException

Specified by:

getVertexStatus in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException

tryKillDAG

public void tryKillDAG()
                throws IOException,
                       org.apache.tez.dag.api.TezException

Specified by:

tryKillDAG in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException

waitForCompletion

public org.apache.tez.dag.api.client.DAGStatus waitForCompletion()
                                                          throws IOException,
                                                                 org.apache.tez.dag.api.TezException,
                                                                 InterruptedException

Specified by:

waitForCompletion in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException

InterruptedException

waitForCompletionWithStatusUpdates

public org.apache.tez.dag.api.client.DAGStatus waitForCompletionWithStatusUpdates(@Nullable
                                                                         Set<org.apache.tez.dag.api.client.StatusGetOpts> statusGetOpts)
                                                                           throws IOException,
                                                                                  org.apache.tez.dag.api.TezException,
                                                                                  InterruptedException

Specified by:

waitForCompletionWithStatusUpdates in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException

InterruptedException

close

public void close()
           throws IOException

Throws:

IOException

getDAGStatus

public org.apache.tez.dag.api.client.DAGStatus getDAGStatus(@Nullable
                                                   Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions,
                                                   long timeout)
                                                     throws IOException,
                                                            org.apache.tez.dag.api.TezException

Specified by:

getDAGStatus in class org.apache.tez.dag.api.client.DAGClient

Throws:

IOException

org.apache.tez.dag.api.TezException