public class TezTimelineClient extends org.apache.tez.dag.api.client.DAGClientTimelineImpl implements TimelineClient
Constructor and Description |
---|
TezTimelineClient(ApplicationId appId,
String dagId,
org.apache.tez.dag.api.TezConfiguration conf,
org.apache.tez.client.FrameworkClient frameworkClient,
org.apache.tez.dag.api.client.DAGClient dagClient) |
Modifier and Type | Method and Description |
---|---|
org.apache.tez.dag.api.client.DAGClient |
getDAGClient() |
org.apache.tez.dag.api.client.DAGStatus |
getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) |
org.apache.tez.client.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(String taskID) |
Iterator<TaskStatus> |
getVertexChildren(String vertexID,
int limit,
String startTaskID) |
String |
getVertexID(String vertexName) |
org.apache.tez.dag.api.client.VertexStatus |
getVertexStatus(String vertexName,
Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) |
public TezTimelineClient(ApplicationId appId, String dagId, org.apache.tez.dag.api.TezConfiguration conf, org.apache.tez.client.FrameworkClient frameworkClient, org.apache.tez.dag.api.client.DAGClient dagClient) throws org.apache.tez.dag.api.TezException
org.apache.tez.dag.api.TezException
public org.apache.tez.dag.api.client.DAGClient getDAGClient()
public org.apache.tez.client.FrameworkClient getFrameworkClient()
public org.apache.tez.dag.api.client.DAGStatus getDAGStatus(@Nullable Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) throws IOException, org.apache.tez.dag.api.TezException
getDAGStatus
in class org.apache.tez.dag.api.client.DAGClientTimelineImpl
IOException
org.apache.tez.dag.api.TezException
public org.apache.tez.dag.api.client.VertexStatus getVertexStatus(String vertexName, Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) throws IOException, org.apache.tez.dag.api.TezException
getVertexStatus
in class org.apache.tez.dag.api.client.DAGClientTimelineImpl
IOException
org.apache.tez.dag.api.TezException
public String getVertexID(String vertexName) throws IOException, org.apache.tez.dag.api.TezException
getVertexID
in interface TimelineClient
IOException
org.apache.tez.dag.api.TezException
public Iterator<TaskStatus> getVertexChildren(String vertexID, int limit, String startTaskID) throws IOException, org.apache.tez.dag.api.TezException
getVertexChildren
in interface TimelineClient
IOException
org.apache.tez.dag.api.TezException
public TaskStatus getVertexChild(String taskID) throws org.apache.tez.dag.api.TezException
getVertexChild
in interface TimelineClient
org.apache.tez.dag.api.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-2015 Concurrent, Inc. All Rights Reserved.