Package | Description |
---|---|
org.apache.tez.dag.api |
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 DAGProtos.PlanEdgeProperty |
DagTypeConverters.convertToProto(EdgeProperty prop) |
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 © 2016 Apache Software Foundation. All rights reserved.