edu.snu.coral.runtime.common.plan

Class RuntimeEdge<V extends Vertex>

java.lang.Object

edu.snu.coral.common.dag.Edge<V>

edu.snu.coral.runtime.common.plan.RuntimeEdge<V>

Type Parameters:

V - the vertex type.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

PhysicalStageEdge, StageEdge

public class RuntimeEdge<V extends Vertex>
extends Edge<V>

Represents the edge between vertices in a logical/physical plan in runtime.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RuntimeEdge(String runtimeEdgeId, ExecutionPropertyMap edgeProperties, V src, V dst, Coder coder) Constructs the edge given the below parameters.
RuntimeEdge(String runtimeEdgeId, ExecutionPropertyMap edgeProperties, V src, V dst, Coder coder, Boolean isSideInput) Constructs the edge given the below parameters.

Method Summary

Modifier and Type	Method and Description
Coder	getCoder()
ExecutionPropertyMap	getExecutionProperties()
<T> T	getProperty(ExecutionProperty.Key executionPropertyKey) Get the execution property of the Runtime Edge.
Boolean	isSideInput()
String	propertiesToJSON()

Methods inherited from class edu.snu.coral.common.dag.Edge

getDst, getId, getNumericId, getSrc

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RuntimeEdge

public RuntimeEdge(String runtimeEdgeId,
                   ExecutionPropertyMap edgeProperties,
                   V src,
                   V dst,
                   Coder coder)

Constructs the edge given the below parameters.

Parameters:

runtimeEdgeId - the id of this edge.

edgeProperties - to control the data flow on this edge.

src - the source vertex.

dst - the destination vertex.

coder - coder.

RuntimeEdge

public RuntimeEdge(String runtimeEdgeId,
                   ExecutionPropertyMap edgeProperties,
                   V src,
                   V dst,
                   Coder coder,
                   Boolean isSideInput)

Constructs the edge given the below parameters.

Parameters:

runtimeEdgeId - the id of this edge.

edgeProperties - to control the data flow on this edge.

src - the source vertex.

dst - the destination vertex.

coder - coder.

isSideInput - Whether or not the RuntimeEdge is a side input edge.

Method Detail

getProperty

public final <T> T getProperty(ExecutionProperty.Key executionPropertyKey)

Get the execution property of the Runtime Edge.

Type Parameters:

T - Type of the return value.

Parameters:

executionPropertyKey - key of the execution property.

Returns:

the execution property.

getExecutionProperties

public final ExecutionPropertyMap getExecutionProperties()

Returns:

the ExecutionPropertyMap of the Runtime Edge.

getCoder

public final Coder getCoder()

Returns:

the coder for encoding and decoding.

isSideInput

public final Boolean isSideInput()

Returns:

whether or not the RuntimeEdge is a side input edge.

propertiesToJSON

public String propertiesToJSON()

Overrides:

propertiesToJSON in class Edge<V extends Vertex>

Returns:

JSON representation of additional properties