@InterfaceAudience.Private public class DAGClientRPCImpl extends DAGClientInternal
Constructor and Description |
---|
DAGClientRPCImpl(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.
|
String |
getExecutionContext()
Gets DAG execution context for use with logging
|
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.
|
public DAGClientRPCImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId, String dagId, TezConfiguration conf, @Nullable FrameworkClient frameworkClient)
public String getExecutionContext()
DAGClientInternal
getExecutionContext
in class DAGClientInternal
public DAGStatus getDAGStatus(Set<StatusGetOpts> statusOptions) throws IOException, TezException, org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
DAGClientInternal
getDAGStatus
in class DAGClientInternal
statusOptions
- Optionally, retrieve additional information based on
specified options. To retrieve basic information, this can be nullIOException
TezException
org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
public DAGStatus getDAGStatus(@Nullable Set<StatusGetOpts> statusOptions, long timeout) throws IOException, TezException, org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
DAGClientInternal
getDAGStatus
in class DAGClientInternal
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 stateIOException
TezException
org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
public VertexStatus getVertexStatus(String vertexName, Set<StatusGetOpts> statusOptions) throws IOException, TezException, org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
DAGClientInternal
getVertexStatus
in class DAGClientInternal
statusOptions
- Optionally, retrieve additional information based on
specified optionsIOException
TezException
org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException
public void tryKillDAG() throws TezException, IOException
DAGClientInternal
tryKillDAG
in class DAGClientInternal
TezException
IOException
public void close() throws IOException
IOException
protected org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReportInternal()
getApplicationReportInternal
in class DAGClientInternal
public DAGStatus waitForCompletion() throws IOException, TezException, InterruptedException
DAGClientInternal
waitForCompletion
in class DAGClientInternal
IOException
TezException
InterruptedException
public DAGStatus waitForCompletionWithStatusUpdates(@Nullable Set<StatusGetOpts> statusGetOpts) throws IOException, TezException, InterruptedException
DAGClientInternal
waitForCompletionWithStatusUpdates
in class DAGClientInternal
statusGetOpts
- : status get options. For example, to get counter pass
EnumSet.of(StatusGetOpts.GET_COUNTERS)
IOException
TezException
InterruptedException
Copyright © 2016 Apache Software Foundation. All rights reserved.