org.apache.flink.runtime.scheduler

Interface InputsLocationsRetriever

All Known Implementing Classes:

ExecutionGraphToInputsLocationsRetrieverAdapter

public interface InputsLocationsRetriever

Component to retrieve the inputs locations of an ExecutionVertex.

Method Summary

Modifier and Type	Method and Description
Collection<ConsumedPartitionGroup>	getConsumedPartitionGroups(ExecutionVertexID executionVertexId) Get the consumed result partition groups of an execution vertex.
Collection<ExecutionVertexID>	getProducersOfConsumedPartitionGroup(ConsumedPartitionGroup consumedPartitionGroup) Get the producer execution vertices of a consumed result partition group.
Optional<CompletableFuture<TaskManagerLocation>>	getTaskManagerLocation(ExecutionVertexID executionVertexId) Get the task manager location future for an execution vertex.

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