Modifier and Type | Method and Description |
---|---|
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph,
JobStatus statusOverride)
Create a
ArchivedExecutionGraph from the given ExecutionGraph . |
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createSparseArchivedExecutionGraph(JobID jobId,
String jobName,
JobStatus jobStatus,
Throwable throwable,
JobCheckpointingSettings checkpointingSettings,
long initializationTimestamp)
Create a sparse ArchivedExecutionGraph for a job.
|
Constructor and Description |
---|
DefaultJobMasterServiceProcess(JobID jobId,
UUID leaderSessionId,
JobMasterServiceFactory jobMasterServiceFactory,
java.util.function.Function<Throwable,ArchivedExecutionGraph> failedArchivedExecutionGraphFactory) |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionGraph |
JobMasterServiceProcessFactory.createArchivedExecutionGraph(JobStatus jobStatus,
Throwable cause)
Creates an
ArchivedExecutionGraph for the job for which this factory creates JobMasterServiceProcess with the given jobStatus and failure cause. |
ArchivedExecutionGraph |
DefaultJobMasterServiceProcessFactory.createArchivedExecutionGraph(JobStatus jobStatus,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ArchivedExecutionGraph> |
MiniCluster.getArchivedExecutionGraph(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionGraph |
ExecutionGraphInfo.getArchivedExecutionGraph() |
Constructor and Description |
---|
ExecutionGraphInfo(ArchivedExecutionGraph executionGraph) |
ExecutionGraphInfo(ArchivedExecutionGraph executionGraph,
Iterable<RootExceptionHistoryEntry> exceptionHistory) |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionGraph |
AdaptiveScheduler.getArchivedExecutionGraph(JobStatus jobStatus,
Throwable cause) |
ArchivedExecutionGraph |
CreatingExecutionGraph.getJob() |
Modifier and Type | Method and Description |
---|---|
void |
StateTransitions.ToFinished.goToFinished(ArchivedExecutionGraph archivedExecutionGraph)
Transitions into the
Finished state. |
void |
AdaptiveScheduler.goToFinished(ArchivedExecutionGraph archivedExecutionGraph) |
void |
AdaptiveScheduler.onFinished(ArchivedExecutionGraph archivedExecutionGraph) |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<ArchivedExecutionGraph> |
RestfulGateway.requestJob(JobID jobId,
Time timeout)
Requests the
ArchivedExecutionGraph for the given jobId. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.