Uses of Class
org.apache.flink.runtime.scheduler.strategy.ExecutionVertexID

Packages that use ExecutionVertexID

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adapter
org.apache.flink.runtime.scheduler.adaptive.allocator
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.exceptionhistory
org.apache.flink.runtime.scheduler.slowtaskdetector
org.apache.flink.runtime.scheduler.strategy

Uses of ExecutionVertexID in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return ExecutionVertexID

Modifier and Type	Method	Description
ExecutionVertexID	ExecutionAttemptID.getExecutionVertexId()
ExecutionVertexID	ExecutionVertex.getID()

Methods in org.apache.flink.runtime.executiongraph with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
void	EdgeManager.connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId, ConsumedPartitionGroup consumedPartitionGroup)
List<ConsumedPartitionGroup>	EdgeManager.getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId)
ExecutionVertex	DefaultExecutionGraph.getExecutionVertexOrThrow(ExecutionVertexID id)
ExecutionVertex	InternalExecutionGraphAccessor.getExecutionVertexOrThrow(ExecutionVertexID id)

Constructors in org.apache.flink.runtime.executiongraph with parameters of type ExecutionVertexID

Constructor	Description
ExecutionAttemptID(ExecutionGraphID executionGraphId, ExecutionVertexID executionVertexId, int attemptNumber)

Uses of ExecutionVertexID in org.apache.flink.runtime.executiongraph.failover.flip1

Methods in org.apache.flink.runtime.executiongraph.failover.flip1 that return types with arguments of type ExecutionVertexID

Modifier and Type	Method	Description
Set<ExecutionVertexID>	FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns a set of IDs corresponding to the set of vertices that should be restarted.
Set<ExecutionVertexID>	RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns all vertices on any task failure.
Set<ExecutionVertexID>	RestartPipelinedRegionFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns a set of IDs corresponding to the set of vertices that should be restarted.
Set<ExecutionVertexID>	FailureHandlingResult.getVerticesToRestart()	Returns the tasks to restart.

Methods in org.apache.flink.runtime.executiongraph.failover.flip1 with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
SchedulingPipelinedRegion	RestartPipelinedRegionFailoverStrategy.getFailoverRegion(ExecutionVertexID vertexID)	Returns the failover region that contains the given execution vertex.
Set<ExecutionVertexID>	FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns a set of IDs corresponding to the set of vertices that should be restarted.
Set<ExecutionVertexID>	RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns all vertices on any task failure.
Set<ExecutionVertexID>	RestartPipelinedRegionFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)	Returns a set of IDs corresponding to the set of vertices that should be restarted.

Method parameters in org.apache.flink.runtime.executiongraph.failover.flip1 with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
static Set<Set<SchedulingExecutionVertex>>	SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices, java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever, java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever)
static FailureHandlingResult	FailureHandlingResult.restartable(Execution failedExecution, Throwable cause, long timestamp, CompletableFuture<Map<String,String>> failureLabels, Set<ExecutionVertexID> verticesToRestart, long restartDelayMS, boolean globalFailure)	Creates a result of a set of tasks to restart to recover from the failure.

Uses of ExecutionVertexID in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease

Methods in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
boolean	RegionPartitionGroupReleaseStrategy.isRegionOfVertexFinished(ExecutionVertexID executionVertexId)
List<ConsumedPartitionGroup>	NotReleasingPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
List<ConsumedPartitionGroup>	PartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)	Calling this method informs the strategy that a vertex finished.
List<ConsumedPartitionGroup>	RegionPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
void	NotReleasingPartitionGroupReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID)
void	PartitionGroupReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID)	Calling this method informs the strategy that a vertex is no longer in finished state, e.g., when a vertex is re-executed.
void	RegionPartitionGroupReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexId)

Method parameters in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
void	RegionPartitionGroupReleaseStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology, List<ExecutionVertexID> newExecutionVertices)

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return ExecutionVertexID

Modifier and Type	Method	Description
ExecutionVertexID	ExecutionVertexVersion.getExecutionVertexId()

Methods in org.apache.flink.runtime.scheduler that return types with arguments of type ExecutionVertexID

Modifier and Type	Method	Description
Map<ExecutionVertexID,ExecutionVertexVersion>	ExecutionVertexVersioner.getExecutionVertexVersions(Collection<ExecutionVertexID> executionVertexIds)
Collection<ExecutionVertexID>	ExecutionGraphToInputsLocationsRetrieverAdapter.getProducersOfConsumedPartitionGroup(ConsumedPartitionGroup consumedPartitionGroup)
Collection<ExecutionVertexID>	InputsLocationsRetriever.getProducersOfConsumedPartitionGroup(ConsumedPartitionGroup consumedPartitionGroup)	Get the producer execution vertices of a consumed result partition group.
Set<ExecutionVertexID>	ExecutionVertexVersioner.getUnmodifiedExecutionVertices(Set<ExecutionVertexVersion> executionVertexVersions)
Map<ExecutionVertexID,ExecutionVertexVersion>	ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices)

Methods in org.apache.flink.runtime.scheduler with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
protected void	DefaultScheduler.cancelAllPendingSlotRequestsForVertex(ExecutionVertexID executionVertexId)
Collection<ConsumedPartitionGroup>	ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedPartitionGroups(ExecutionVertexID executionVertexId)
Collection<ConsumedPartitionGroup>	InputsLocationsRetriever.getConsumedPartitionGroups(ExecutionVertexID executionVertexId)	Get the consumed result partition groups of an execution vertex.
ExecutionVertex	SchedulerBase.getExecutionVertex(ExecutionVertexID executionVertexId)
CompletableFuture<Collection<TaskManagerLocation>>	DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)
CompletableFuture<Collection<TaskManagerLocation>>	PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)	Returns preferred locations of an execution vertex.
Collection<TaskManagerLocation>	SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)	Returns preferred locations of an execution vertex.
Optional<TaskManagerLocation>	StateLocationRetriever.getStateLocation(ExecutionVertexID executionVertexId)	Returns state location of an execution vertex.
Optional<CompletableFuture<TaskManagerLocation>>	ExecutionGraphToInputsLocationsRetrieverAdapter.getTaskManagerLocation(ExecutionVertexID executionVertexId)
Optional<CompletableFuture<TaskManagerLocation>>	InputsLocationsRetriever.getTaskManagerLocation(ExecutionVertexID executionVertexId)	Get the task manager location future for an execution vertex.
ExecutionVertexVersion	ExecutionVertexVersioner.recordModification(ExecutionVertexID executionVertexId)
protected void	SchedulerBase.resetForNewExecution(ExecutionVertexID executionVertexId)

Method parameters in org.apache.flink.runtime.scheduler with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
void	DefaultExecutionDeployer.allocateSlotsAndDeploy(List<Execution> executionsToDeploy, Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex)
void	DefaultScheduler.allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy)
void	ExecutionDeployer.allocateSlotsAndDeploy(List<Execution> executionsToDeploy, Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex)	Allocate slots and deploy executions.
void	SchedulerOperations.allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy)	Allocate slots and deploy the vertex when slots are returned.
DefaultExecutionDeployer	DefaultExecutionDeployer.Factory.createInstance(org.slf4j.Logger log, ExecutionSlotAllocator executionSlotAllocator, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, org.apache.flink.api.common.time.Time partitionRegistrationTimeout, java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc, org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor mainThreadExecutor)
ExecutionDeployer	ExecutionDeployer.Factory.createInstance(org.slf4j.Logger log, ExecutionSlotAllocator executionSlotAllocator, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, org.apache.flink.api.common.time.Time partitionRegistrationTimeout, java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc, org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor mainThreadExecutor)	Instantiate an ExecutionDeployer with the given params.
Map<ExecutionVertexID,ExecutionVertexVersion>	ExecutionVertexVersioner.getExecutionVertexVersions(Collection<ExecutionVertexID> executionVertexIds)
CompletableFuture<Collection<TaskManagerLocation>>	DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)
CompletableFuture<Collection<TaskManagerLocation>>	PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)	Returns preferred locations of an execution vertex.
Collection<TaskManagerLocation>	SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId, Set<ExecutionVertexID> producersToIgnore)	Returns preferred locations of an execution vertex.
void	SchedulingTopologyListener.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology, List<ExecutionVertexID> newExecutionVertices)	Notifies that the scheduling topology is just updated.
Map<ExecutionVertexID,ExecutionVertexVersion>	ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices)
protected void	SchedulerBase.resetForNewExecutions(Collection<ExecutionVertexID> vertices)
protected void	SchedulerBase.restoreState(Set<ExecutionVertexID> vertices, boolean isGlobalRecovery)
void	VertexEndOfDataListener.restoreVertices(Set<ExecutionVertexID> executionVertices)
protected void	SchedulerBase.transitionToScheduled(List<ExecutionVertexID> verticesToDeploy)

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.adapter

Methods in org.apache.flink.runtime.scheduler.adapter with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
boolean	DefaultSchedulingPipelinedRegion.contains(ExecutionVertexID vertexId)
DefaultSchedulingPipelinedRegion	DefaultExecutionTopology.getPipelinedRegionOfVertex(ExecutionVertexID vertexId)
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex	DefaultExecutionTopology.getVertex(ExecutionVertexID executionVertexId)
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex	DefaultSchedulingPipelinedRegion.getVertex(ExecutionVertexID vertexId)

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.adaptive.allocator

Methods in org.apache.flink.runtime.scheduler.adaptive.allocator with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
LogicalSlot	ReservedSlots.getSlotFor(ExecutionVertexID executionVertexId)

Method parameters in org.apache.flink.runtime.scheduler.adaptive.allocator with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
static ReservedSlots	ReservedSlots.create(Map<ExecutionVertexID,LogicalSlot> assignedSlots)

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
SpeculativeExecutionVertex	SpeculativeScheduler.getExecutionVertex(ExecutionVertexID executionVertexId)
protected void	AdaptiveBatchScheduler.resetForNewExecution(ExecutionVertexID executionVertexId)
protected void	SpeculativeScheduler.resetForNewExecution(ExecutionVertexID executionVertexId)

Method parameters in org.apache.flink.runtime.scheduler.adaptivebatch with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
void	AdaptiveBatchScheduler.allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy)
void	SpeculativeScheduler.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks)

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.exceptionhistory

Method parameters in org.apache.flink.runtime.scheduler.exceptionhistory with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
static FailureHandlingResultSnapshot	FailureHandlingResultSnapshot.create(FailureHandlingResult failureHandlingResult, java.util.function.Function<ExecutionVertexID,Collection<Execution>> currentExecutionsLookup)	Creates a FailureHandlingResultSnapshot based on the passed FailureHandlingResult and ExecutionVertices.

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.slowtaskdetector

Method parameters in org.apache.flink.runtime.scheduler.slowtaskdetector with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
void	SlowTaskDetectorListener.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks)	Notify detected slow tasks.

Uses of ExecutionVertexID in org.apache.flink.runtime.scheduler.strategy

Methods in org.apache.flink.runtime.scheduler.strategy that return ExecutionVertexID

Modifier and Type	Method	Description
static ExecutionVertexID	ExecutionVertexID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
ExecutionVertexID	ConsumerVertexGroup.getFirst()

Methods in org.apache.flink.runtime.scheduler.strategy that return types with arguments of type ExecutionVertexID

Modifier and Type	Method	Description
Iterator<ExecutionVertexID>	ConsumerVertexGroup.iterator()

Methods in org.apache.flink.runtime.scheduler.strategy with parameters of type ExecutionVertexID

Modifier and Type	Method	Description
static ConsumerVertexGroup	ConsumerVertexGroup.fromSingleVertex(ExecutionVertexID vertex, ResultPartitionType resultPartitionType)
SchedulingExecutionVertex	SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)	Looks up the SchedulingExecutionVertex for the given ExecutionVertexID.
void	PipelinedRegionSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId, ExecutionState executionState)
void	SchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId, ExecutionState executionState)	Called whenever an Execution changes its state.
void	VertexwiseSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId, ExecutionState executionState)

Method parameters in org.apache.flink.runtime.scheduler.strategy with type arguments of type ExecutionVertexID

Modifier and Type	Method	Description
InputConsumableDecider	AllFinishedInputConsumableDecider.Factory.createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)
InputConsumableDecider	DefaultInputConsumableDecider.Factory.createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)
InputConsumableDecider	InputConsumableDecider.Factory.createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)
InputConsumableDecider	PartialFinishedInputConsumableDecider.Factory.createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)
static ConsumerVertexGroup	ConsumerVertexGroup.fromMultipleVertices(List<ExecutionVertexID> vertices, ResultPartitionType resultPartitionType)
boolean	AllFinishedInputConsumableDecider.isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToDeploy, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)
boolean	DefaultInputConsumableDecider.isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToSchedule, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)
boolean	InputConsumableDecider.isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToSchedule, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)	Determining whether the input of an execution vertex is consumable.
boolean	PartialFinishedInputConsumableDecider.isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToDeploy, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)
void	VertexwiseSchedulingStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology, List<ExecutionVertexID> newExecutionVertices)
void	PipelinedRegionSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)
void	SchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)	Called whenever vertices need to be restarted (due to task failure).
void	VertexwiseSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)