org.apache.tez.dag.app.dag

Interface DAG

All Known Implementing Classes:

DAGImpl

public interface DAG

Main interface to interact with the job.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.tez.common.security.ACLManager	getACLManager()
org.apache.tez.common.counters.TezCounters	getAllCounters() Get all the counters of this DAG.
org.apache.hadoop.conf.Configuration	getConf()
org.apache.hadoop.security.Credentials	getCredentials()
DAGStatusBuilder	getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
DAGStatusBuilder	getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions, long timeout)
org.apache.hadoop.security.UserGroupInformation	getDagUGI()
List<String>	getDiagnostics()
org.apache.hadoop.yarn.event.EventHandler	getEventHandler()
org.apache.tez.dag.records.TezDAGID	getID()
org.apache.tez.dag.api.records.DAGProtos.DAGPlan	getJobPlan()
Map<String,org.apache.hadoop.yarn.api.records.LocalResource>	getLocalResources()
String	getName()
float	getProgress()
DAGReport	getReport()
DAGState	getState()
int	getSuccessfulVertices()
int	getTotalVertices()
String	getUserName()
Vertex	getVertex(String vertexName) Get Vertex by vertex name
Vertex	getVertex(org.apache.tez.dag.records.TezVertexID vertexId)
Map<String,org.apache.tez.dag.records.TezVertexID>	getVertexNameIDMapping()
VertexStatusBuilder	getVertexStatus(String vertexName, Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)
Map<org.apache.tez.dag.records.TezVertexID,Vertex>	getVertices()
boolean	isComplete()
boolean	isUber()
DAGState	restoreFromEvent(HistoryEvent historyEvent)

Method Detail

getID

org.apache.tez.dag.records.TezDAGID getID()

getLocalResources

Map<String,org.apache.hadoop.yarn.api.records.LocalResource> getLocalResources()

getName

String getName()

getState

DAGState getState()

getReport

DAGReport getReport()

getAllCounters

org.apache.tez.common.counters.TezCounters getAllCounters()

Get all the counters of this DAG. This includes job-counters aggregated together with the counters of each task. This creates a clone of the Counters, so use this judiciously.

Returns:

job-counters and aggregate task-counters

getEventHandler

org.apache.hadoop.yarn.event.EventHandler getEventHandler()

getVertex

Vertex getVertex(String vertexName)

Get Vertex by vertex name

getVertices

Map<org.apache.tez.dag.records.TezVertexID,Vertex> getVertices()

getVertex

Vertex getVertex(org.apache.tez.dag.records.TezVertexID vertexId)

getDiagnostics

List<String> getDiagnostics()

getTotalVertices

int getTotalVertices()

getSuccessfulVertices

int getSuccessfulVertices()

getProgress

float getProgress()

isUber

boolean isUber()

getUserName

String getUserName()

getConf

org.apache.hadoop.conf.Configuration getConf()

getJobPlan

org.apache.tez.dag.api.records.DAGProtos.DAGPlan getJobPlan()

getDAGStatus

DAGStatusBuilder getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)

getDAGStatus

DAGStatusBuilder getDAGStatus(Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions,
                            long timeout)
                              throws org.apache.tez.dag.api.TezException

Throws:

org.apache.tez.dag.api.TezException

getVertexStatus

VertexStatusBuilder getVertexStatus(String vertexName,
                                  Set<org.apache.tez.dag.api.client.StatusGetOpts> statusOptions)

isComplete

boolean isComplete()

getCredentials

org.apache.hadoop.security.Credentials getCredentials()

getDagUGI

org.apache.hadoop.security.UserGroupInformation getDagUGI()

restoreFromEvent

DAGState restoreFromEvent(HistoryEvent historyEvent)

getACLManager

org.apache.tez.common.security.ACLManager getACLManager()

getVertexNameIDMapping

Map<String,org.apache.tez.dag.records.TezVertexID> getVertexNameIDMapping()