org.apache.tez.dag.api.client

Class DAGClientInternal

java.lang.Object

org.apache.tez.dag.api.client.DAGClientInternal

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

DAGClientRPCImpl, DAGClientTimelineImpl

@InterfaceAudience.Private
public abstract class DAGClientInternal
extends Object
implements Closeable

Private internal class for monitoring the DAG running in a Tez DAG Application Master.

Constructor Summary

Constructors

Constructor and Description
DAGClientInternal()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReportInternal()
abstract DAGStatus	getDAGStatus(Set<StatusGetOpts> statusOptions) Get the status of the specified DAG
abstract DAGStatus	getDAGStatus(Set<StatusGetOpts> statusOptions, long timeout) Get the status of the specified DAG when it reaches a final state, or the timeout expires.
abstract String	getExecutionContext() Gets DAG execution context for use with logging
abstract VertexStatus	getVertexStatus(String vertexName, Set<StatusGetOpts> statusOptions) Get the status of a Vertex of a DAG
abstract void	tryKillDAG() Kill a running DAG
abstract DAGStatus	waitForCompletion() Wait for DAG to complete without printing any vertex statuses
abstract DAGStatus	waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) Wait for DAG to complete and periodically print *all* vertices' status.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

DAGClientInternal

public DAGClientInternal()

Method Detail

getExecutionContext

public abstract String getExecutionContext()

Gets DAG execution context for use with logging

Returns:

summary of DAG execution

getApplicationReportInternal

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

getDAGStatus

public abstract DAGStatus getDAGStatus(@Nullable
                     Set<StatusGetOpts> statusOptions)
                                throws IOException,
                                       TezException,
                                       org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

Get the status of the specified DAG

Parameters:

statusOptions - Optionally, retrieve additional information based on specified options. To retrieve basic information, this can be null

Throws:

IOException

TezException

org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

getDAGStatus

public abstract DAGStatus getDAGStatus(@Nullable
                     Set<StatusGetOpts> statusOptions,
                     long timeout)
                                throws IOException,
                                       TezException,
                                       org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

Get the status of the specified DAG when it reaches a final state, or the timeout expires.

Parameters:

statusOptions - Optionally, retrieve additional information based on specified options. To retrieve basic information, this can be null

timeout - RPC call timeout. Value -1 waits for infinite and returns when DAG reaches final state

Returns:

DAG Status

Throws:

IOException

TezException

org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

getVertexStatus

public abstract VertexStatus getVertexStatus(String vertexName,
                           Set<StatusGetOpts> statusOptions)
                                      throws IOException,
                                             TezException,
                                             org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

Get the status of a Vertex of a DAG

Parameters:

statusOptions - Optionally, retrieve additional information based on specified options

Throws:

IOException

TezException

org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException

tryKillDAG

public abstract void tryKillDAG()
                         throws IOException,
                                TezException

Kill a running DAG

Throws:

IOException

TezException

waitForCompletion

public abstract DAGStatus waitForCompletion()
                                     throws IOException,
                                            TezException,
                                            InterruptedException

Wait for DAG to complete without printing any vertex statuses

Returns:

Final DAG Status

Throws:

IOException

TezException

InterruptedException

waitForCompletionWithStatusUpdates

public abstract DAGStatus waitForCompletionWithStatusUpdates(@Nullable
                                           Set<StatusGetOpts> statusGetOpts)
                                                      throws IOException,
                                                             TezException,
                                                             InterruptedException

Wait for DAG to complete and periodically print *all* vertices' status.

Parameters:

statusGetOpts - : status get options. For example, to get counter pass EnumSet.of(StatusGetOpts.GET_COUNTERS)

Returns:

Final DAG Status

Throws:

IOException

TezException

InterruptedException