Interface InputsLocationsRetriever

    • Method Detail

      • getConsumedPartitionGroups

        Collection<ConsumedPartitionGroup> getConsumedPartitionGroups​(ExecutionVertexID executionVertexId)
        Get the consumed result partition groups of an execution vertex.
        Parameters:
        executionVertexId - identifies the execution vertex
        Returns:
        the consumed result partition groups
      • getProducersOfConsumedPartitionGroup

        Collection<ExecutionVertexID> getProducersOfConsumedPartitionGroup​(ConsumedPartitionGroup consumedPartitionGroup)
        Get the producer execution vertices of a consumed result partition group.
        Parameters:
        consumedPartitionGroup - the consumed result partition group
        Returns:
        the ids of producer execution vertices
      • getTaskManagerLocation

        Optional<CompletableFuture<TaskManagerLocation>> getTaskManagerLocation​(ExecutionVertexID executionVertexId)
        Get the task manager location future for an execution vertex.
        Parameters:
        executionVertexId - identifying the execution vertex
        Returns:
        the task manager location future