Class RuntimeEdge<V extends Vertex>

  • 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 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
      • getPropertiesAsJsonNode

        public com.fasterxml.jackson.databind.node.ObjectNode getPropertiesAsJsonNode()
        Overrides:
        getPropertiesAsJsonNode in class Edge<V extends Vertex>
        Returns:
        JSON representation of additional properties