@InterfaceAudience.Public @InterfaceStability.Evolving public class TaskLocationHint extends Object
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() |
public static TaskLocationHint createTaskLocationHint(String vertexName, int taskIndex)
VertexManagerPlugin
s
and not in while creating the dag using the DAG API.vertexName
- taskIndex
- public static TaskLocationHint createTaskLocationHint(Set<String> hosts, Set<String> racks)
public org.apache.tez.dag.api.TaskLocationHint.TaskBasedLocationAffinity getAffinitizedTask()
Copyright © 2024 Apache Software Foundation. All rights reserved.