@InterfaceAudience.Public @InterfaceStability.Evolving public class TaskLocationHint extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TaskLocationHint.TaskBasedLocationAffinity |
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) |
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 TaskLocationHint.TaskBasedLocationAffinity getAffinitizedTask()
Copyright © 2016 Apache Software Foundation. All rights reserved.