Class Stage

    • Method Detail

      • getSerializedIRDAG

        public byte[] getSerializedIRDAG()
        Returns:
        the serialized DAG of the task.
      • getTaskIndices

        public List<Integer> getTaskIndices()
        Returns:
        task indices of this stage to execute. For non-sampling vertices, returns [0, 1, 2, ..., parallelism-1]. For sampling vertices, returns a list of size (parallelism * samplingRate).
      • getParallelism

        public int getParallelism()
        Returns:
        the parallelism.
      • getScheduleGroup

        public int getScheduleGroup()
        Returns:
        the schedule group.
      • getPropertyValue

        public <T extends SerializableOptional<T> getPropertyValue​(Class<? extends VertexExecutionProperty<T>> executionPropertyKey)
        Get the executionProperty of the IREdge.
        Type Parameters:
        T - Type of the return value.
        Parameters:
        executionPropertyKey - key of the execution property.
        Returns:
        the execution property.
      • getVertexIdToReadables

        public List<Map<String,​Readable>> getVertexIdToReadables()
        Returns:
        the list of maps between vertex ID and readables.
      • getPropertiesAsJsonNode

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