org.apache.tez.dag.api

Interface EdgeManagerPluginContext

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public interface EdgeManagerPluginContext

Context information provided to EdgeManagerPlugins This interface is not supposed to be implemented by users

Method Summary

Modifier and Type	Method and Description
String	getDestinationVertexName() Returns the destination vertex name
int	getDestinationVertexNumTasks() Returns the number of tasks in the destination vertex
String	getSourceVertexName() Returns the source vertex name
int	getSourceVertexNumTasks() Returns the number of tasks in the source vertex
UserPayload	getUserPayload() Returns the payload specified by the user for the edge.
String	getVertexGroupName()

Method Detail

getUserPayload

UserPayload getUserPayload()

Returns the payload specified by the user for the edge.

Returns:

the UserPayload specified by the user

getSourceVertexName

String getSourceVertexName()

Returns the source vertex name

Returns:

the source vertex name

getDestinationVertexName

String getDestinationVertexName()

Returns the destination vertex name

Returns:

the destination vertex name

getSourceVertexNumTasks

int getSourceVertexNumTasks()

Returns the number of tasks in the source vertex

getDestinationVertexNumTasks

int getDestinationVertexNumTasks()

Returns the number of tasks in the destination vertex

getVertexGroupName

String getVertexGroupName()

Returns:

the name of vertex group that source vertex belongs to, or null