Package org.apache.flink.runtime.executiongraph

Interface InternalExecutionGraphAccessor

All Known Implementing Classes:

DefaultExecutionGraph

public interface InternalExecutionGraphAccessor

This interface encapsulates all methods needed by ExecutionJobVertex / ExecutionVertices / Execution from the DefaultExecutionGraph.

Method Summary

Modifier and Type	Method	Description
void	deleteBlobs(List<PermanentBlobKey> blobKeys)
void	deregisterExecution(Execution exec)
void	failGlobal(Throwable t)	Fails the execution graph globally.
BlobWriter	getBlobWriter()
List<ShuffleDescriptor>	getClusterPartitionShuffleDescriptors(IntermediateDataSetID intermediateResultPartition)	Get the shuffle descriptors of the cluster partitions ordered by partition number.
EdgeManager	getEdgeManager()
ExecutionDeploymentListener	getExecutionDeploymentListener()
ExecutionGraphID	getExecutionGraphID()
ExecutionVertex	getExecutionVertexOrThrow(ExecutionVertexID id)
Executor	getFutureExecutor()	Returns the ExecutionContext associated with this ExecutionGraph.
JobID	getJobID()
ComponentMainThreadExecutor	getJobMasterMainThreadExecutor()
ExecutionJobVertex	getJobVertex(JobVertexID id)
JobVertexInputInfo	getJobVertexInputInfo(JobVertexID jobVertexId, IntermediateDataSetID resultId)	Get the input info of a certain input of a certain job vertex.
MarkPartitionFinishedStrategy	getMarkPartitionFinishedStrategy()
PartitionGroupReleaseStrategy	getPartitionGroupReleaseStrategy()
JobMasterPartitionTracker	getPartitionTracker()
IntermediateResultPartition	getResultPartitionOrThrow(IntermediateResultPartitionID id)
ShuffleMaster<? extends ShuffleDescriptor>	getShuffleMaster()
TaskDeploymentDescriptorFactory	getTaskDeploymentDescriptorFactory()
ClassLoader	getUserClassLoader()
boolean	isDynamic()
void	jobVertexFinished()
void	jobVertexUnFinished()
void	notifyExecutionChange(Execution execution, ExecutionState previousState, ExecutionState newExecutionState)
void	notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId, Throwable t, boolean cancelTask, boolean releasePartitions)
void	registerExecution(Execution exec)

Method Detail

getUserClassLoader

ClassLoader getUserClassLoader()

getJobID

JobID getJobID()

getBlobWriter

BlobWriter getBlobWriter()

getFutureExecutor

Executor getFutureExecutor()

Returns the ExecutionContext associated with this ExecutionGraph.

Returns:

ExecutionContext associated with this ExecutionGraph

getJobMasterMainThreadExecutor

@Nonnull
ComponentMainThreadExecutor getJobMasterMainThreadExecutor()

getShuffleMaster

ShuffleMaster<? extends ShuffleDescriptor> getShuffleMaster()

getPartitionTracker

JobMasterPartitionTracker getPartitionTracker()

registerExecution

void registerExecution(Execution exec)

deregisterExecution

void deregisterExecution(Execution exec)

getPartitionGroupReleaseStrategy

PartitionGroupReleaseStrategy getPartitionGroupReleaseStrategy()

jobVertexFinished

void jobVertexFinished()

jobVertexUnFinished

void jobVertexUnFinished()

getExecutionDeploymentListener

ExecutionDeploymentListener getExecutionDeploymentListener()

failGlobal

void failGlobal(Throwable t)

Fails the execution graph globally.

This global failure is meant to be triggered in cases where the consistency of the execution graph' state cannot be guaranteed any more (for example when catching unexpected exceptions that indicate a bug or an unexpected call race), and where a full restart is the safe way to get consistency back.

Parameters:

t - The exception that caused the failure.

notifyExecutionChange

void notifyExecutionChange(Execution execution,
                           ExecutionState previousState,
                           ExecutionState newExecutionState)

notifySchedulerNgAboutInternalTaskFailure

void notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId,
                                               Throwable t,
                                               boolean cancelTask,
                                               boolean releasePartitions)

getEdgeManager

EdgeManager getEdgeManager()

getExecutionVertexOrThrow

ExecutionVertex getExecutionVertexOrThrow(ExecutionVertexID id)

getResultPartitionOrThrow

IntermediateResultPartition getResultPartitionOrThrow(IntermediateResultPartitionID id)

deleteBlobs

void deleteBlobs(List<PermanentBlobKey> blobKeys)

getJobVertex

ExecutionJobVertex getJobVertex(JobVertexID id)

isDynamic

boolean isDynamic()

getExecutionGraphID

ExecutionGraphID getExecutionGraphID()

getClusterPartitionShuffleDescriptors

List<ShuffleDescriptor> getClusterPartitionShuffleDescriptors(IntermediateDataSetID intermediateResultPartition)

Get the shuffle descriptors of the cluster partitions ordered by partition number.

getMarkPartitionFinishedStrategy

MarkPartitionFinishedStrategy getMarkPartitionFinishedStrategy()

getJobVertexInputInfo

JobVertexInputInfo getJobVertexInputInfo(JobVertexID jobVertexId,
                                         IntermediateDataSetID resultId)

Get the input info of a certain input of a certain job vertex.

Parameters:

jobVertexId - the job vertex id

resultId - the input(intermediate result) id

Returns:

the input info

getTaskDeploymentDescriptorFactory

TaskDeploymentDescriptorFactory getTaskDeploymentDescriptorFactory()