@InterfaceAudience.Private public class DAGClientTimelineImpl extends DAGClientInternal
Modifier and Type | Class and Description |
---|---|
protected static class |
DAGClientTimelineImpl.VertexTaskStats |
Constructor and Description |
---|
DAGClientTimelineImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String dagId,
TezConfiguration conf,
FrameworkClient frameworkClient,
int connTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected org.apache.hadoop.yarn.api.records.ApplicationReport |
getApplicationReportInternal() |
protected com.sun.jersey.api.client.Client |
getCachedHttpClient() |
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
|
protected org.codehaus.jettison.json.JSONObject |
getJsonRootEntity(String url) |
VertexStatus |
getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
static boolean |
isSupported() |
protected Map<String,DAGClientTimelineImpl.VertexTaskStats> |
parseTaskStatsForVertexes() |
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 String baseUri
public DAGClientTimelineImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId, String dagId, TezConfiguration conf, FrameworkClient frameworkClient, int connTimeout) throws TezException
TezException
public static boolean isSupported()
public String getExecutionContext()
DAGClientInternal
getExecutionContext
in class DAGClientInternal
protected org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReportInternal()
getApplicationReportInternal
in class DAGClientInternal
public DAGStatus getDAGStatus(@Nullable Set<StatusGetOpts> statusOptions) throws IOException, TezException
DAGClientInternal
getDAGStatus
in class DAGClientInternal
statusOptions
- Optionally, retrieve additional information based on
specified options. To retrieve basic information, this can be nullIOException
TezException
public VertexStatus getVertexStatus(String vertexName, Set<StatusGetOpts> statusOptions) throws IOException, TezException
DAGClientInternal
getVertexStatus
in class DAGClientInternal
statusOptions
- Optionally, retrieve additional information based on
specified optionsIOException
TezException
public void tryKillDAG() throws IOException, TezException
DAGClientInternal
tryKillDAG
in class DAGClientInternal
IOException
TezException
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
public void close() throws IOException
IOException
protected Map<String,DAGClientTimelineImpl.VertexTaskStats> parseTaskStatsForVertexes() throws TezException, org.codehaus.jettison.json.JSONException
TezException
org.codehaus.jettison.json.JSONException
protected org.codehaus.jettison.json.JSONObject getJsonRootEntity(String url) throws TezException
TezException
protected com.sun.jersey.api.client.Client getCachedHttpClient() throws IOException
IOException
public DAGStatus getDAGStatus(@Nullable Set<StatusGetOpts> statusOptions, long timeout) throws IOException, TezException
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
Copyright © 2016 Apache Software Foundation. All rights reserved.