| Package | Description | 
|---|---|
| org.apache.tez.dag.api | 
| Modifier and Type | Method and Description | 
|---|---|
static EdgeProperty | 
EdgeProperty.create(EdgeManagerPluginDescriptor edgeManagerDescriptor,
      org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType,
      org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
      org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
      OutputDescriptor edgeSource,
      InputDescriptor edgeDestination)  | 
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 
 | 
static EdgeProperty | 
EdgeProperty.create(org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType,
      org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
      org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
      OutputDescriptor edgeSource,
      InputDescriptor edgeDestination)
Setup an EdgeProperty which makes use of one of the provided  
EdgeProperty.DataMovementTypes | 
EdgeProperty | 
GroupInputEdge.getEdgeProperty()  | 
EdgeProperty | 
Edge.getEdgeProperty()
The @link  
EdgeProperty for this edge | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,EdgeProperty> | 
VertexManagerPluginContext.getInputVertexEdgeProperties()
Get the edge properties on the input edges of this vertex. 
 | 
Map<String,EdgeProperty> | 
VertexManagerPluginContext.getOutputVertexEdgeProperties()
Get the edge properties on the output edges of this vertex. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static GroupInputEdge | 
GroupInputEdge.create(VertexGroup inputVertexGroup,
      Vertex outputVertex,
      EdgeProperty edgeProperty,
      InputDescriptor mergedInput)
An Edge that connects a  
VertexGroup to a destination Vertex. | 
static Edge | 
Edge.create(Vertex inputVertex,
      Vertex outputVertex,
      EdgeProperty edgeProperty)
Creates an edge between the specified vertices. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
VertexManagerPluginContext.reconfigureVertex(int parallelism,
                 VertexLocationHint locationHint,
                 Map<String,EdgeProperty> sourceEdgeProperties)
API to reconfigure a  
Vertex by changing its task parallelism. | 
void | 
VertexManagerPluginContext.reconfigureVertex(int parallelism,
                 VertexLocationHint locationHint,
                 Map<String,EdgeProperty> sourceEdgeProperties,
                 Map<String,InputSpecUpdate> rootInputSpecUpdate)
API to reconfigure a  
Vertex that is reading root inputs based on
 the data read from the root inputs. | 
Copyright © 2017 Apache Software Foundation. All rights reserved.