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

Class RuntimeEdge<V extends Vertex>

java.lang.Object

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

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

Type Parameters:

V - the vertex type.

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

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	Description
RuntimeEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> executionProperties, V src, V dst)	Constructs the edge given the below parameters.

Method Summary

Modifier and Type	Method	Description
ExecutionPropertyMap<EdgeExecutionProperty>	getExecutionProperties()
com.fasterxml.jackson.databind.node.ObjectNode	getPropertiesAsJsonNode()
<T extends java.io.Serializable> java.util.Optional<T>	getPropertyValue(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)	Get the execution property of the Runtime Edge.
<T extends java.io.Serializable> T	getPropertyValueOrRuntimeException(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)

Methods inherited from class org.apache.nemo.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(java.lang.String runtimeEdgeId,
                   ExecutionPropertyMap<EdgeExecutionProperty> executionProperties,
                   V src,
                   V dst)

Constructs the edge given the below parameters.

Parameters:

runtimeEdgeId - the id of this edge.

executionProperties - to control the data flow on this edge.

src - the source vertex.

dst - the destination vertex.

Method Detail

getPropertyValue

public final <T extends java.io.Serializable> java.util.Optional<T> getPropertyValue(java.lang.Class<? extends EdgeExecutionProperty<T>> 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.

getPropertyValueOrRuntimeException

public final <T extends java.io.Serializable> T getPropertyValueOrRuntimeException(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)

Type Parameters:

T - type

Parameters:

executionPropertyKey - key

Returns:

the value

getExecutionProperties

public final ExecutionPropertyMap<EdgeExecutionProperty> getExecutionProperties()

Returns:

the ExecutionPropertyMap of the Runtime Edge.

getPropertiesAsJsonNode

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

Overrides:

getPropertiesAsJsonNode in class Edge<V extends Vertex>

Returns:

JSON representation of additional properties