org.apache.tez.dag.api

Class Vertex.VertexExecutionContext

java.lang.Object

org.apache.tez.dag.api.Vertex.VertexExecutionContext

Enclosing class:

Vertex

@InterfaceAudience.Public
@InterfaceStability.Unstable
public static class Vertex.VertexExecutionContext
extends Object

The execution context for a running vertex.

Method Summary

Methods

Modifier and Type	Method and Description
static Vertex.VertexExecutionContext	create(String taskSchedulerName, String containerLauncherName, String taskCommName)
static Vertex.VertexExecutionContext	createExecuteInAm(boolean executeInAm) Create an execution context which specifies whether the vertex needs to be executed in the AM
static Vertex.VertexExecutionContext	createExecuteInContainers(boolean executeInContainers) Create an execution context which specifies whether the vertex needs to be executed in regular containers
boolean	equals(Object o)
String	getContainerLauncherName()
String	getTaskCommName()
String	getTaskSchedulerName()
int	hashCode()
boolean	shouldExecuteInAm()
boolean	shouldExecuteInContainers()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

createExecuteInAm

public static Vertex.VertexExecutionContext createExecuteInAm(boolean executeInAm)

Create an execution context which specifies whether the vertex needs to be executed in the AM

Parameters:

executeInAm - whether to execute the vertex in the AM

Returns:

the relevant execution context

createExecuteInContainers

public static Vertex.VertexExecutionContext createExecuteInContainers(boolean executeInContainers)

Create an execution context which specifies whether the vertex needs to be executed in regular containers

Parameters:

executeInContainers - whether to execute the vertex in regular containers

Returns:

the relevant execution context

create

public static Vertex.VertexExecutionContext create(String taskSchedulerName,
                                   String containerLauncherName,
                                   String taskCommName)

Parameters:

taskSchedulerName - the task scheduler name which was setup while creating the TezClient

containerLauncherName - the container launcher name which was setup while creating the TezClient

taskCommName - the task communicator name which was setup while creating the TezClient

Returns:

the relevant execution context

shouldExecuteInAm

public boolean shouldExecuteInAm()

shouldExecuteInContainers

public boolean shouldExecuteInContainers()

getTaskSchedulerName

public String getTaskSchedulerName()

getContainerLauncherName

public String getContainerLauncherName()

getTaskCommName

public String getTaskCommName()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object