public class TezTimelineClient extends DAGClientTimelineImpl implements TimelineClient
DAGClientTimelineImpl.VertexTaskStats
baseUri
Constructor and Description |
---|
TezTimelineClient(ApplicationId appId,
java.lang.String dagId,
TezConfiguration conf,
FrameworkClient frameworkClient,
DAGClient dagClient) |
Modifier and Type | Method and Description |
---|---|
DAGClient |
getDAGClient() |
DAGStatus |
getDAGStatus(java.util.Set<StatusGetOpts> statusOptions) |
FrameworkClient |
getFrameworkClient() |
protected org.codehaus.jettison.json.JSONObject |
getJsonObject(org.codehaus.jettison.json.JSONArray entitiesNode,
int index) |
protected org.codehaus.jettison.json.JSONObject |
getRemoveJsonObject(org.codehaus.jettison.json.JSONArray entitiesNode,
int index,
boolean doRemove) |
TaskStatus |
getVertexChild(java.lang.String taskID) |
java.util.Iterator<TaskStatus> |
getVertexChildren(java.lang.String vertexID,
int limit,
java.lang.String startTaskID) |
java.lang.String |
getVertexID(java.lang.String vertexName) |
VertexStatus |
getVertexStatus(java.lang.String vertexName,
java.util.Set<StatusGetOpts> statusOptions) |
close, getApplicationReportInternal, getCachedHttpClient, getDAGStatus, getExecutionContext, getJsonRootEntity, isSupported, parseTaskStatsForVertexes, tryKillDAG, waitForCompletion, waitForCompletionWithStatusUpdates
public TezTimelineClient(ApplicationId appId, java.lang.String dagId, TezConfiguration conf, FrameworkClient frameworkClient, DAGClient dagClient) throws TezException
TezException
public DAGClient getDAGClient()
public FrameworkClient getFrameworkClient()
public DAGStatus getDAGStatus(@Nullable java.util.Set<StatusGetOpts> statusOptions) throws java.io.IOException, TezException
getDAGStatus
in class DAGClientTimelineImpl
java.io.IOException
TezException
public VertexStatus getVertexStatus(java.lang.String vertexName, java.util.Set<StatusGetOpts> statusOptions) throws java.io.IOException, TezException
getVertexStatus
in class DAGClientTimelineImpl
java.io.IOException
TezException
public java.lang.String getVertexID(java.lang.String vertexName) throws java.io.IOException, TezException
getVertexID
in interface TimelineClient
java.io.IOException
TezException
public java.util.Iterator<TaskStatus> getVertexChildren(java.lang.String vertexID, int limit, java.lang.String startTaskID) throws java.io.IOException, TezException
getVertexChildren
in interface TimelineClient
java.io.IOException
TezException
public TaskStatus getVertexChild(java.lang.String taskID) throws TezException
getVertexChild
in interface TimelineClient
TezException
protected org.codehaus.jettison.json.JSONObject getRemoveJsonObject(org.codehaus.jettison.json.JSONArray entitiesNode, int index, boolean doRemove)
protected org.codehaus.jettison.json.JSONObject getJsonObject(org.codehaus.jettison.json.JSONArray entitiesNode, int index)
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.