Class Task

    • Constructor Detail

      • Task

        public Task​(String planId,
                    String taskId,
                    ExecutionPropertyMap<VertexExecutionProperty> executionProperties,
                    byte[] serializedIRDag,
                    List<StageEdge> taskIncomingEdges,
                    List<StageEdge> taskOutgoingEdges,
                    Map<String,​Readable> irVertexIdToReadable)
        Constructor.
        Parameters:
        planId - the id of the physical plan.
        taskId - the ID of this task attempt.
        executionProperties - VertexExecutionProperty map for the corresponding stage
        serializedIRDag - the serialized DAG of the task.
        taskIncomingEdges - the incoming edges of the task.
        taskOutgoingEdges - the outgoing edges of the task.
        irVertexIdToReadable - the map between IRVertex id to readable.
    • Method Detail

      • getPlanId

        public String getPlanId()
        Returns:
        the id of the plan.
      • getSerializedIRDag

        public byte[] getSerializedIRDag()
        Returns:
        the serialized IR DAG of the task.
      • getTaskId

        public String getTaskId()
        Returns:
        the ID of the task.
      • getTaskIncomingEdges

        public List<StageEdge> getTaskIncomingEdges()
        Returns:
        the incoming edges of the task.
      • getTaskOutgoingEdges

        public List<StageEdge> getTaskOutgoingEdges()
        Returns:
        the outgoing edges of the task.
      • getAttemptIdx

        public int getAttemptIdx()
        Returns:
        the attempt index.
      • getPropertyValue

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

        public Map<String,​Readable> getIrVertexIdToReadable()
        Returns:
        the map between IRVertex id and readable.