org.apache.tez.dag.api

Class VertexGroup

java.lang.Object

org.apache.tez.dag.api.VertexGroup

@InterfaceAudience.Public
public class VertexGroup
extends Object

Represents a virtual collection of vertices whose members can be treated as a single named collection for graph operations. Only the following connections are valid. A VertexGroup can be connected as an input to a consumer Vertex. The tasks of the destination vertex see a single input named after the VertexGroup instead multiple inputs from the members of the VertexGroup. An output can be added to a VertexGroup. All outgoing edges & outputs of a VertexGroup are automatically transferred to the member vertices of the VertexGroup. A VertexGroup is not part of the final DAG.

Method Summary

Modifier and Type	Method and Description
VertexGroup	addDataSink(String outputName, DataSinkDescriptor dataSinkDescriptor) Add an common data sink to the group of vertices.
boolean	equals(Object obj)
String	getGroupName() Get the name of the group
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getGroupName

public String getGroupName()

Get the name of the group

Returns:

name

addDataSink

public VertexGroup addDataSink(String outputName,
                               DataSinkDescriptor dataSinkDescriptor)

Add an common data sink to the group of vertices. Refer to Vertex.addDataSink(String, DataSinkDescriptor)

Returns:

this object for further chained method calls

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