Package | Description |
---|---|
org.apache.tez.dag.api | |
org.apache.tez.runtime.api.events |
Modifier and Type | Method and Description |
---|---|
static VertexLocationHint |
VertexLocationHint.create(List<TaskLocationHint> taskLocationHints) |
VertexLocationHint |
DataSourceDescriptor.getLocationHint()
Get the location hints for the tasks in the vertex for this data source.
|
Modifier and Type | Method and Description |
---|---|
static DataSourceDescriptor |
DataSourceDescriptor.create(InputDescriptor inputDescriptor,
InputInitializerDescriptor initializerDescriptor,
int numShards,
org.apache.hadoop.security.Credentials credentials,
VertexLocationHint locationHint,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> additionalLocalFiles)
Create a
DataSourceDescriptor when the data shard calculation
happens in the client at compile time |
Vertex |
Vertex.setLocationHint(VertexLocationHint locationHint)
Specify location hints for the tasks of this vertex.
|
void |
VertexManagerPluginContext.setVertexLocationHint(VertexLocationHint locationHint)
Set the placement hint for tasks in this vertex
|
void |
VertexManagerPluginContext.setVertexParallelism(int parallelism,
VertexLocationHint locationHint,
Map<String,EdgeManagerPluginDescriptor> sourceEdgeManagers,
Map<String,InputSpecUpdate> rootInputSpecUpdate)
Set the new parallelism (number of tasks) of this vertex,
Map of source (input) vertices and edge managers to change the event routing
between the source tasks and the new destination tasks and the number of physical inputs for root inputs.
|
Modifier and Type | Method and Description |
---|---|
VertexLocationHint |
InputConfigureVertexTasksEvent.getLocationHint() |
Modifier and Type | Method and Description |
---|---|
static InputConfigureVertexTasksEvent |
InputConfigureVertexTasksEvent.create(int numTasks,
VertexLocationHint locationHint,
InputSpecUpdate inputSpecUpdate) |
Copyright © 2015 Apache Software Foundation. All rights reserved.