org.apache.tez.dag.api

Class GroupInputEdge

java.lang.Object

org.apache.tez.dag.api.GroupInputEdge

@InterfaceAudience.Public
public class GroupInputEdge
extends Object

A composite edge that represents a common connection between a group of input vertices and a single output vertex. This can be used to perform e.g. an efficient union of the data produced by the input vertices. The output vertex tasks see a unified/merged view of the data from all the input vertices.

Method Summary

Modifier and Type	Method and Description
static GroupInputEdge	create(VertexGroup inputVertexGroup, Vertex outputVertex, EdgeProperty edgeProperty, InputDescriptor mergedInput) An Edge that connects a VertexGroup to a destination Vertex.
boolean	equals(Object obj)
EdgeProperty	getEdgeProperty()
VertexGroup	getInputVertexGroup()
Vertex	getOutputVertex()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

create

public static GroupInputEdge create(VertexGroup inputVertexGroup,
                                    Vertex outputVertex,
                                    EdgeProperty edgeProperty,
                                    InputDescriptor mergedInput)

An Edge that connects a VertexGroup to a destination Vertex. The framework takes care of connecting the VertexGroup members with the destination vertex. The tasks of the destination vertex see only 1 input named after the VertexGroup instead of individual inputs from group members. These individual inputs are merged using the mergedInput before presenting them to the destination task.

Parameters:

inputVertexGroup - source VertexGroup

outputVertex - destination Vertex

edgeProperty - the common EdgeProperty for this GroupInputEdge

mergedInput - MergedLogicalInput This input is responsible for merging the data from the input vertex tasks to create a single input for the output vertex tasks

getInputVertexGroup

public VertexGroup getInputVertexGroup()

getOutputVertex

public Vertex getOutputVertex()

getEdgeProperty

public EdgeProperty getEdgeProperty()

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object