org.apache.pig.backend.hadoop.executionengine.tez

Class TezJob

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.tez.TezJob

All Implemented Interfaces:

Runnable

public class TezJob
extends Object
implements Runnable

Wrapper class that encapsulates Tez DAG. This class mediates between Tez DAGs and JobControl.

Constructor Summary

Constructors

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)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TezJob

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

Throws:

IOException

Method Detail

getDAG

public org.apache.tez.dag.api.DAG getDAG()

getName

public String getName()

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

getApplicationId

public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()

getDAGStatus

public org.apache.tez.dag.api.client.DAGStatus getDAGStatus()

getDAGCounters

public org.apache.tez.common.counters.TezCounters getDAGCounters()

getDAGProgress

public float getDAGProgress()

getVertexProgress

public Map<String,Float> getVertexProgress()

getVertexStatus

public org.apache.tez.dag.api.client.VertexStatus getVertexStatus(String vertexName)

setPigStats

public void setPigStats(TezPigScriptStats pigStats)

run

public void run()

Specified by:

run in interface Runnable

killJob

public void killJob()
             throws IOException

Throws:

IOException

getDiagnostics

public String getDiagnostics()