org.apache.hadoop.hive.ql.exec.tez

Class TezTask.SyncDagClient

java.lang.Object

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

org.apache.hadoop.hive.ql.exec.tez.TezTask.SyncDagClient

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

TezTask

public class TezTask.SyncDagClient
extends org.apache.tez.dag.api.client.DAGClient

DAG client that does dumb global sync on all the method calls; Tez DAG client is not thread safe and getting the 2nd one is not recommended.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
protected org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReportInternal()
String	getDagIdentifierString()
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()
String	getSessionIdentifierString()
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

SyncDagClient

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

Method Detail

close

public void close()
           throws IOException

Throws:

IOException

getDagIdentifierString

public String getDagIdentifierString()

Specified by:

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

getSessionIdentifierString

public String getSessionIdentifierString()

Specified by:

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

getExecutionContext

public String getExecutionContext()

Specified by:

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

getApplicationReportInternal

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

Specified by:

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

getDAGStatus

public org.apache.tez.dag.api.client.DAGStatus getDAGStatus(@Nullable
                                                            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

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

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