Constructor and Description |
---|
TezJob(org.apache.tez.dag.api.TezConfiguration conf,
org.apache.tez.dag.api.DAG dag,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> requestAMResources,
TezOperPlan tezPlan) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId() |
org.apache.hadoop.conf.Configuration |
getConfiguration() |
org.apache.tez.dag.api.DAG |
getDAG() |
org.apache.tez.common.counters.TezCounters |
getDAGCounters() |
float |
getDAGProgress() |
org.apache.tez.dag.api.client.DAGStatus |
getDAGStatus() |
String |
getDiagnostics() |
String |
getName() |
Map<String,Float> |
getVertexProgress() |
org.apache.tez.dag.api.client.VertexStatus |
getVertexStatus(String vertexName) |
void |
killJob() |
void |
run() |
void |
setPigStats(TezPigScriptStats pigStats) |
public TezJob(org.apache.tez.dag.api.TezConfiguration conf, org.apache.tez.dag.api.DAG dag, Map<String,org.apache.hadoop.yarn.api.records.LocalResource> requestAMResources, TezOperPlan tezPlan) throws IOException
IOException
public org.apache.tez.dag.api.DAG getDAG()
public String getName()
public org.apache.hadoop.conf.Configuration getConfiguration()
public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()
public org.apache.tez.dag.api.client.DAGStatus getDAGStatus()
public org.apache.tez.common.counters.TezCounters getDAGCounters()
public float getDAGProgress()
public org.apache.tez.dag.api.client.VertexStatus getVertexStatus(String vertexName)
public void setPigStats(TezPigScriptStats pigStats)
public void killJob() throws IOException
IOException
public String getDiagnostics()
Copyright © 2007-2017 The Apache Software Foundation