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

Class TezJob

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

public class TezJob
extends java.lang.Object
implements java.lang.Runnable

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

Constructor Summary

Constructors

Constructor and Description
TezJob(TezConfiguration conf, DAG dag, java.util.Map<java.lang.String,LocalResource> requestAMResources, int estimatedTotalParallelism)

Method Summary

Methods

Modifier and Type	Method and Description
ApplicationId	getApplicationId()
org.apache.hadoop.conf.Configuration	getConfiguration()
DAG	getDAG()
TezCounters	getDAGCounters()
float	getDAGProgress()
DAGStatus	getDAGStatus()
java.lang.String	getDiagnostics()
java.lang.String	getName()
java.util.Map<java.lang.String,java.lang.Float>	getVertexProgress()
VertexStatus	getVertexStatus(java.lang.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(TezConfiguration conf,
      DAG dag,
      java.util.Map<java.lang.String,LocalResource> requestAMResources,
      int estimatedTotalParallelism)
       throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getDAG

public DAG getDAG()

getName

public java.lang.String getName()

getConfiguration

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

getApplicationId

public ApplicationId getApplicationId()

getDAGStatus

public DAGStatus getDAGStatus()

getDAGCounters

public TezCounters getDAGCounters()

getDAGProgress

public float getDAGProgress()

getVertexProgress

public java.util.Map<java.lang.String,java.lang.Float> getVertexProgress()

getVertexStatus

public VertexStatus getVertexStatus(java.lang.String vertexName)

setPigStats

public void setPigStats(TezPigScriptStats pigStats)

run

public void run()

Specified by:

run in interface java.lang.Runnable

killJob

public void killJob()
             throws java.io.IOException

Throws:

java.io.IOException

getDiagnostics

public java.lang.String getDiagnostics()