@InterfaceAudience.Private public class DAGClientImpl extends DAGClient
Modifier and Type | Field and Description |
---|---|
protected boolean |
isATSEnabled |
protected DAGClientInternal |
realClient |
Constructor and Description |
---|
DAGClientImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String dagId,
TezConfiguration conf,
FrameworkClient frameworkClient) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected org.apache.hadoop.yarn.api.records.ApplicationReport |
getApplicationReportInternal() |
DAGStatus |
getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG
|
DAGStatus |
getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires.
|
protected DAGStatus |
getDAGStatusViaRM()
Get the DAG status via the YARN ResourceManager
|
String |
getExecutionContext()
Gets DAG execution context for use with logging
|
DAGClientInternal |
getRealClient() |
VertexStatus |
getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
void |
tryKillDAG()
Kill a running DAG
|
DAGStatus |
waitForCompletion()
Wait for DAG to complete without printing any vertex statuses
|
DAGStatus |
waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status.
|
protected DAGClientInternal realClient
protected boolean isATSEnabled
public DAGClientImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId, String dagId, TezConfiguration conf, @Nullable FrameworkClient frameworkClient)
public String getExecutionContext()
DAGClient
getExecutionContext
in class DAGClient
protected org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReportInternal()
getApplicationReportInternal
in class DAGClient
public DAGStatus getDAGStatus(@Nullable Set<StatusGetOpts> statusOptions, long timeout) throws TezException, IOException
DAGClient
getDAGStatus
in class DAGClient
statusOptions
- Optionally, retrieve additional information based on
specified options. To retrieve basic information, this can be nulltimeout
- RPC call timeout. Value -1 waits for infinite and returns when
DAG reaches final stateTezException
IOException
public DAGStatus getDAGStatus(@Nullable Set<StatusGetOpts> statusOptions) throws TezException, IOException
DAGClient
getDAGStatus
in class DAGClient
statusOptions
- Optionally, retrieve additional information based on
specified options. To retrieve basic information, this can be nullTezException
IOException
public VertexStatus getVertexStatus(String vertexName, Set<StatusGetOpts> statusOptions) throws IOException, TezException
DAGClient
getVertexStatus
in class DAGClient
statusOptions
- Optionally, retrieve additional information based on
specified optionsIOException
TezException
public void tryKillDAG() throws IOException, TezException
DAGClient
tryKillDAG
in class DAGClient
IOException
TezException
public DAGStatus waitForCompletion() throws IOException, TezException, InterruptedException
DAGClient
waitForCompletion
in class DAGClient
IOException
TezException
InterruptedException
public DAGStatus waitForCompletionWithStatusUpdates(@Nullable Set<StatusGetOpts> statusGetOpts) throws IOException, TezException, InterruptedException
DAGClient
waitForCompletionWithStatusUpdates
in class DAGClient
statusGetOpts
- : status get options. For example, to get counter pass
EnumSet.of(StatusGetOpts.GET_COUNTERS)
IOException
TezException
InterruptedException
public void close() throws IOException
IOException
protected DAGStatus getDAGStatusViaRM() throws TezException, IOException
TezException
IOException
public DAGClientInternal getRealClient()
Copyright © 2016 Apache Software Foundation. All rights reserved.