Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static EdgeManagerPluginDescriptor |
EdgeManagerPluginDescriptor.create(String edgeManagerPluginClassName) |
EdgeManagerPluginDescriptor |
EdgeProperty.getEdgeManagerDescriptor()
Returns the Edge Manager specifications for this edge.
|
Modifier and Type | Method and Description |
---|---|
static EdgeProperty |
EdgeProperty.create(EdgeManagerPluginDescriptor edgeManagerDescriptor,
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
OutputDescriptor edgeSource,
InputDescriptor edgeDestination)
Setup an Edge which uses a custom EdgeManager
|
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2015 Apache Software Foundation. All rights reserved.