public class TezTask.SyncDagClient
extends org.apache.tez.dag.api.client.DAGClient
Constructor and Description |
---|
SyncDagClient(org.apache.tez.dag.api.client.DAGClient dagClient) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected org.apache.hadoop.yarn.api.records.ApplicationReport |
getApplicationReportInternal() |
org.apache.tez.dag.api.client.DAGStatus |
getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) |
org.apache.tez.dag.api.client.DAGStatus |
getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions,
long timeout) |
String |
getExecutionContext() |
org.apache.tez.dag.api.client.VertexStatus |
getVertexStatus(String vertexName,
Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions) |
void |
tryKillDAG() |
org.apache.tez.dag.api.client.DAGStatus |
waitForCompletion() |
org.apache.tez.dag.api.client.DAGStatus |
waitForCompletionWithStatusUpdates(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusGetOpts) |
public SyncDagClient(org.apache.tez.dag.api.client.DAGClient dagClient)
public void close() throws IOException
IOException
public String getExecutionContext()
getExecutionContext
in class org.apache.tez.dag.api.client.DAGClient
@InterfaceAudience.Private protected org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReportInternal()
getApplicationReportInternal
in class org.apache.tez.dag.api.client.DAGClient
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.DAGClient
IOException
org.apache.tez.dag.api.TezException
public org.apache.tez.dag.api.client.DAGStatus getDAGStatus(@Nullable Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions, long timeout) throws IOException, org.apache.tez.dag.api.TezException
getDAGStatus
in class org.apache.tez.dag.api.client.DAGClient
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.DAGClient
IOException
org.apache.tez.dag.api.TezException
public void tryKillDAG() throws IOException, org.apache.tez.dag.api.TezException
tryKillDAG
in class org.apache.tez.dag.api.client.DAGClient
IOException
org.apache.tez.dag.api.TezException
public org.apache.tez.dag.api.client.DAGStatus waitForCompletion() throws IOException, org.apache.tez.dag.api.TezException, InterruptedException
waitForCompletion
in class org.apache.tez.dag.api.client.DAGClient
IOException
org.apache.tez.dag.api.TezException
InterruptedException
public org.apache.tez.dag.api.client.DAGStatus waitForCompletionWithStatusUpdates(@Nullable Set<org.apache.tez.dag.api.client.StatusGetOpts> statusGetOpts) throws IOException, org.apache.tez.dag.api.TezException, InterruptedException
waitForCompletionWithStatusUpdates
in class org.apache.tez.dag.api.client.DAGClient
IOException
org.apache.tez.dag.api.TezException
InterruptedException
Copyright © 2016 The Apache Software Foundation. All rights reserved.