public interface InternalExecutionGraphAccessor
ClassLoader getUserClassLoader()
JobID getJobID()
BlobWriter getBlobWriter()
Executor getFutureExecutor()
@Nonnull ComponentMainThreadExecutor getJobMasterMainThreadExecutor()
ShuffleMaster<? extends ShuffleDescriptor> getShuffleMaster()
JobMasterPartitionTracker getPartitionTracker()
void registerExecution(Execution exec)
void deregisterExecution(Execution exec)
PartitionGroupReleaseStrategy getPartitionGroupReleaseStrategy()
void jobVertexFinished()
void jobVertexUnFinished()
ExecutionDeploymentListener getExecutionDeploymentListener()
void failGlobal(Throwable t)
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.
t
- The exception that caused the failure.void notifyExecutionChange(Execution execution, ExecutionState previousState, ExecutionState newExecutionState)
void notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId, Throwable t, boolean cancelTask, boolean releasePartitions)
EdgeManager getEdgeManager()
ExecutionVertex getExecutionVertexOrThrow(ExecutionVertexID id)
IntermediateResultPartition getResultPartitionOrThrow(IntermediateResultPartitionID id)
void deleteBlobs(List<PermanentBlobKey> blobKeys)
ExecutionJobVertex getJobVertex(JobVertexID id)
boolean isDynamic()
ExecutionGraphID getExecutionGraphID()
List<ShuffleDescriptor> getClusterPartitionShuffleDescriptors(IntermediateDataSetID intermediateResultPartition)
MarkPartitionFinishedStrategy getMarkPartitionFinishedStrategy()
JobVertexInputInfo getJobVertexInputInfo(JobVertexID jobVertexId, IntermediateDataSetID resultId)
jobVertexId
- the job vertex idresultId
- the input(intermediate result) idTaskDeploymentDescriptorFactory getTaskDeploymentDescriptorFactory()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.