| Package | Description | 
|---|---|
| org.apache.tez.client | |
| org.apache.tez.dag.api | |
| org.apache.tez.dag.api.client | |
| org.apache.tez.runtime.api | 
| Modifier and Type | Method and Description | 
|---|---|
protected org.apache.tez.dag.api.client.rpc.DAGClientAMProtocolBlockingPB | 
TezClient.getAMProxy(org.apache.hadoop.yarn.api.records.ApplicationId appId)  | 
TezAppMasterStatus | 
TezClient.getAppMasterStatus()
Get the status of the App Master executing the DAG
 In non-session mode it returns the status of the last submitted DAG App Master 
 In session mode, it returns the status of the App Master hosting the session 
 | 
void | 
TezClient.preWarm(PreWarmVertex preWarmVertex)
API to help pre-allocate containers in session mode. 
 | 
void | 
TezClient.preWarm(PreWarmVertex preWarmVertex,
       long timeout,
       TimeUnit unit)
API to help pre-allocate containers in session mode. 
 | 
void | 
TezClient.start()
Start the client. 
 | 
void | 
TezClient.stop()
Stop the client. 
 | 
DAGClient | 
TezClient.submitDAG(DAG dag)
Submit a DAG. 
 | 
void | 
TezClient.waitTillReady()
Wait till the DAG is ready to be submitted. 
 | 
boolean | 
TezClient.waitTillReady(long timeout,
             TimeUnit unit)
Wait till the DAG is ready to be submitted. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DAGSubmissionTimedOut
Exception thrown when DAG submission to a Tez Session times out. 
 | 
class  | 
SessionNotRunning
Exception thrown when the client cannot communicate with the Tez Session
 as the Tez Session is no longer running. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
abstract DAGStatus | 
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG 
 | 
abstract DAGStatus | 
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions,
            long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires. 
 | 
abstract VertexStatus | 
DAGClient.getVertexStatus(String vertexName,
               Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG 
 | 
abstract void | 
DAGClient.tryKillDAG()
Kill a running DAG 
 | 
abstract DAGStatus | 
DAGClient.waitForCompletion()
Wait for DAG to complete without printing any vertex statuses 
 | 
abstract DAGStatus | 
DAGClient.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ProgressFailedException  | 
Copyright © 2018 Apache Software Foundation. All rights reserved.