org.apache.tez.dag.api

Class TaskLocationHint

java.lang.Object

org.apache.tez.dag.api.TaskLocationHint

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class TaskLocationHint
extends Object

Describes the placements hints for tasks. The system will make a best-effort attempt to run the tasks close to the specified locations.

Method Summary

Modifier and Type	Method and Description
static TaskLocationHint	createTaskLocationHint(Set<String> hosts, Set<String> racks) Provides a location hint with nodes and racks at which the task may be executed.
static TaskLocationHint	createTaskLocationHint(String vertexName, int taskIndex) Provide a location hint that affinitizes to the given task in the given vertex.
boolean	equals(Object obj)
org.apache.tez.dag.api.TaskLocationHint.TaskBasedLocationAffinity	getAffinitizedTask()
Set<String>	getHosts()
Set<String>	getRacks()
int	hashCode()

Methods inherited from class java.lang.Object

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

Method Detail

createTaskLocationHint

public static TaskLocationHint createTaskLocationHint(String vertexName,
                                                      int taskIndex)

Provide a location hint that affinitizes to the given task in the given vertex. Tez will try to run in the same container as the given task or node local to it. Locality may degrade to rack local or further depending on cluster resource allocations.
This is expected to be used only during dynamic optimizations via VertexManagerPlugins and not in while creating the dag using the DAG API.

Parameters:

vertexName -

taskIndex -

Returns:

the task location hint for the vertex name and task index

createTaskLocationHint

public static TaskLocationHint createTaskLocationHint(Set<String> hosts,
                                                      Set<String> racks)

Provides a location hint with nodes and racks at which the task may be executed. Tez will try to execute the task at those locations

getAffinitizedTask

public org.apache.tez.dag.api.TaskLocationHint.TaskBasedLocationAffinity getAffinitizedTask()

getHosts

public Set<String> getHosts()

getRacks

public Set<String> getRacks()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object