@InterfaceAudience.Private public class DAGClientTimelineImpl extends DAGClient
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()
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) throws IOException, TezException
DAGClient
getDAGStatus
in class DAGClient
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
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 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
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 stateIOException
TezException
Copyright © 2016 Apache Software Foundation. All rights reserved.