Package org.apache.nemo.runtime.common.plan

Class StageEdge

java.lang.Object

org.apache.nemo.common.dag.Edge<V>

org.apache.nemo.runtime.common.plan.RuntimeEdge<Stage>

org.apache.nemo.runtime.common.plan.StageEdge

All Implemented Interfaces:

java.io.Serializable

public final class StageEdge
extends RuntimeEdge<Stage>

Edge of a stage that connects an IRVertex of the source stage to an IRVertex of the destination stage. This means that there can be multiple StageEdges between two Stages.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StageEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, IRVertex srcVertex, IRVertex dstVertex, Stage srcStage, Stage dstStage)	Constructor.

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
CommunicationPatternProperty.Value	getDataCommunicationPattern()
DataFlowProperty.Value	getDataFlowModel()
IRVertex	getDstIRVertex()
java.util.List<KeyRange>	getKeyRanges()	Get keyRanges for shuffle edge.
com.fasterxml.jackson.databind.node.ObjectNode	getPropertiesAsJsonNode()
IRVertex	getSrcIRVertex()
int	hashCode()
java.lang.Boolean	hasSameItineraryAs(StageEdge edge)
java.lang.String	toString()

Methods inherited from class org.apache.nemo.runtime.common.plan.RuntimeEdge

getExecutionProperties, getPropertyValue, getPropertyValueOrRuntimeException

Methods inherited from class org.apache.nemo.common.dag.Edge

getDst, getId, getNumericId, getSrc

Methods inherited from class java.lang.Object

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

Constructor Detail

StageEdge

public StageEdge(java.lang.String runtimeEdgeId,
                 ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties,
                 IRVertex srcVertex,
                 IRVertex dstVertex,
                 Stage srcStage,
                 Stage dstStage)

Constructor.

Parameters:

runtimeEdgeId - id of the runtime edge.

edgeProperties - edge execution properties.

srcVertex - source IRVertex in the srcStage of this edge.

dstVertex - destination IRVertex in the dstStage of this edge.

srcStage - source stage.

dstStage - destination stage.

Method Detail

getSrcIRVertex

public IRVertex getSrcIRVertex()

Returns:

the source IR vertex of the edge.

getDstIRVertex

public IRVertex getDstIRVertex()

Returns:

the destination IR vertex of the edge.

getPropertiesAsJsonNode

public com.fasterxml.jackson.databind.node.ObjectNode getPropertiesAsJsonNode()

Overrides:

getPropertiesAsJsonNode in class RuntimeEdge<Stage>

Returns:

JSON representation of additional properties

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

hasSameItineraryAs

public java.lang.Boolean hasSameItineraryAs(StageEdge edge)

Parameters:

edge - edge to compare.

Returns:

whether or not the edge has the same itinerary

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getDataCommunicationPattern

public CommunicationPatternProperty.Value getDataCommunicationPattern()

Returns:

CommunicationPatternProperty value.

getDataFlowModel

public DataFlowProperty.Value getDataFlowModel()

Returns:

DataFlowProperty value.

getKeyRanges

public java.util.List<KeyRange> getKeyRanges()

Get keyRanges for shuffle edge. If the destination vertex is enabled for dynamic task sizing,

Returns:

SubPartitionSetProperty value. Else,