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 |
---|---|
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
|
TezClient |
TezClient.getClient(org.apache.hadoop.yarn.api.records.ApplicationId appId)
Alternative to start() that explicitly sets sessionAppId and doesn't start a new AM.
|
TezClient |
TezClient.getClient(String appIdStr) |
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 String |
DAGClient.getWebUIAddress()
Returns the Tez AM's web ui address if any.
|
abstract void |
DAGClient.tryKillDAG()
Kill a running DAG
|
abstract DAGStatus |
DAGClient.waitForCompletion()
Wait forever for DAG to complete without printing any vertex statuses
|
DAGStatus |
DAGClient.waitForCompletion(long timeMs)
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 © 2024 Apache Software Foundation. All rights reserved.