org.apache.flink.runtime.jobmaster

Interface ExecutionDeploymentTracker

All Known Implementing Classes:

DefaultExecutionDeploymentTracker

public interface ExecutionDeploymentTracker

A tracker for deployed executions.

Method Summary

Modifier and Type	Method and Description
void	completeDeploymentOf(ExecutionAttemptID executionAttemptId) Marks the deployment of the given execution as complete.
Map<ExecutionAttemptID,ExecutionDeploymentState>	getExecutionsOn(ResourceID host) Returns all tracked executions for the given host.
void	startTrackingPendingDeploymentOf(ExecutionAttemptID executionAttemptId, ResourceID host) Starts tracking the given execution that is being deployed on the given host.
void	stopTrackingDeploymentOf(ExecutionAttemptID executionAttemptId) Stops tracking the given execution.

Method Detail

startTrackingPendingDeploymentOf

void startTrackingPendingDeploymentOf(ExecutionAttemptID executionAttemptId,
                                      ResourceID host)

Starts tracking the given execution that is being deployed on the given host.

Parameters:

executionAttemptId - execution to start tracking

host - hosting task executor

completeDeploymentOf

void completeDeploymentOf(ExecutionAttemptID executionAttemptId)

Marks the deployment of the given execution as complete.

Parameters:

executionAttemptId - execution whose deployment to mark as complete

stopTrackingDeploymentOf

void stopTrackingDeploymentOf(ExecutionAttemptID executionAttemptId)

Stops tracking the given execution.

Parameters:

executionAttemptId - execution to stop tracking

getExecutionsOn

Map<ExecutionAttemptID,ExecutionDeploymentState> getExecutionsOn(ResourceID host)

Returns all tracked executions for the given host.

Parameters:

host - hosting task executor

Returns:

tracked executions