Package | Description |
---|---|
org.apache.tez.client | |
org.apache.tez.dag.api | |
org.apache.tez.dag.api.client |
Modifier and Type | Method and Description |
---|---|
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
|
protected org.apache.tez.dag.api.client.rpc.DAGClientAMProtocolBlockingPB |
TezClient.getSessionAMProxy(org.apache.hadoop.yarn.api.records.ApplicationId appId) |
void |
TezClient.preWarm(PreWarmVertex preWarmVertex)
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.
|
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 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.
|
Copyright © 2015 Apache Software Foundation. All rights reserved.