Interface AccessExecutionJobVertex

    • Method Detail

      • getName

        String getName()
        Returns the name for this job vertex.
        Returns:
        name for this job vertex.
      • getParallelism

        int getParallelism()
        Returns the parallelism for this job vertex.
        Returns:
        parallelism for this job vertex.
      • getMaxParallelism

        int getMaxParallelism()
        Returns the max parallelism for this job vertex.
        Returns:
        max parallelism for this job vertex.
      • getSlotSharingGroup

        SlotSharingGroup getSlotSharingGroup()
        Returns the slot sharing group for this job vertex.
        Returns:
        slot sharing group for this job vertex.
      • getResourceProfile

        ResourceProfile getResourceProfile()
        Returns the resource profile for this job vertex.
        Returns:
        resource profile for this job vertex.
      • getJobVertexId

        JobVertexID getJobVertexId()
        Returns the JobVertexID for this job vertex.
        Returns:
        JobVertexID for this job vertex.
      • getTaskVertices

        AccessExecutionVertex[] getTaskVertices()
        Returns all execution vertices for this job vertex.
        Returns:
        all execution vertices for this job vertex
      • getAggregateState

        ExecutionState getAggregateState()
        Returns the aggregated ExecutionState for this job vertex.
        Returns:
        aggregated state for this job vertex
      • getAggregatedUserAccumulatorsStringified

        StringifiedAccumulatorResult[] getAggregatedUserAccumulatorsStringified()
        Returns the aggregated user-defined accumulators as strings.
        Returns:
        aggregated user-defined accumulators as strings.