Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static EdgeManagerPluginDescriptor |
EdgeManagerPluginDescriptor.create(String edgeManagerPluginClassName) |
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)
Deprecated.
|
Copyright © 2024 Apache Software Foundation. All rights reserved.