org.apache.flink.runtime.scheduler

Interface InputsLocationsRetriever

All Known Implementing Classes:

ExecutionGraphToInputsLocationsRetrieverAdapter

public interface InputsLocationsRetriever

Component to retrieve the inputs locations of a Execution.

Method Summary

Modifier and Type	Method and Description
Collection<Collection<ExecutionVertexID>>	getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) Get the producers of the result partitions consumed by an execution.
Optional<CompletableFuture<TaskManagerLocation>>	getTaskManagerLocation(ExecutionVertexID executionVertexId) Get the task manager location future for an execution.

Method Detail

getConsumedResultPartitionsProducers

Collection<Collection<ExecutionVertexID>> getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)

Get the producers of the result partitions consumed by an execution.

Parameters:

executionVertexId - identifies the execution

Returns:

the producers of the result partitions group by job vertex id

getTaskManagerLocation

Optional<CompletableFuture<TaskManagerLocation>> getTaskManagerLocation(ExecutionVertexID executionVertexId)

Get the task manager location future for an execution.

Parameters:

executionVertexId - identifying the execution

Returns:

the task manager location future