Uses of Class
org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph

Packages that use ArchivedExecutionGraph

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.webmonitor

Uses of ArchivedExecutionGraph in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return ArchivedExecutionGraph

Modifier and Type	Method and Description
ArchivedExecutionGraph	ArchivedExecutionGraphStore.get(JobID jobId) Get the ArchivedExecutionGraph for the given job id.
ArchivedExecutionGraph	MemoryArchivedExecutionGraphStore.get(JobID jobId)
ArchivedExecutionGraph	FileArchivedExecutionGraphStore.get(JobID jobId)

Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type ArchivedExecutionGraph

Modifier and Type	Method and Description
CompletableFuture<ArchivedExecutionGraph>	DispatcherGateway.requestJob(JobID jobId, Time timeout) Requests the ArchivedExecutionGraph for the given jobId.
CompletableFuture<ArchivedExecutionGraph>	Dispatcher.requestJob(JobID jobId, Time timeout)

Methods in org.apache.flink.runtime.dispatcher with parameters of type ArchivedExecutionGraph

Modifier and Type	Method and Description
protected void	Dispatcher.jobReachedGloballyTerminalState(ArchivedExecutionGraph archivedExecutionGraph)
protected void	MiniDispatcher.jobReachedGloballyTerminalState(ArchivedExecutionGraph archivedExecutionGraph)
void	ArchivedExecutionGraphStore.put(ArchivedExecutionGraph archivedExecutionGraph) Store the given ArchivedExecutionGraph in the store.
void	MemoryArchivedExecutionGraphStore.put(ArchivedExecutionGraph serializableExecutionGraph)
void	FileArchivedExecutionGraphStore.put(ArchivedExecutionGraph archivedExecutionGraph)

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

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

Modifier and Type	Method and Description
static ArchivedExecutionGraph	ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph) Create a ArchivedExecutionGraph from the given ExecutionGraph.

Uses of ArchivedExecutionGraph in org.apache.flink.runtime.jobmanager

Methods in org.apache.flink.runtime.jobmanager with parameters of type ArchivedExecutionGraph

Modifier and Type	Method and Description
void	OnCompletionActions.jobReachedGloballyTerminalState(ArchivedExecutionGraph executionGraph) Job reached a globally terminal state.

Uses of ArchivedExecutionGraph in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return types with arguments of type ArchivedExecutionGraph

Modifier and Type	Method and Description
CompletableFuture<ArchivedExecutionGraph>	JobManagerRunner.getResultFuture() Get the result future of this runner.
CompletableFuture<ArchivedExecutionGraph>	JobManagerRunnerImpl.getResultFuture()
CompletableFuture<ArchivedExecutionGraph>	JobMaster.requestJob(Time timeout)
CompletableFuture<ArchivedExecutionGraph>	JobMasterGateway.requestJob(Time timeout) Requests the ArchivedExecutionGraph of the executed job.

Methods in org.apache.flink.runtime.jobmaster with parameters of type ArchivedExecutionGraph

Modifier and Type	Method and Description
void	JobManagerRunnerImpl.jobReachedGloballyTerminalState(ArchivedExecutionGraph executionGraph) Job completion notification triggered by JobManager.

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

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

Modifier and Type	Method and Description
ArchivedExecutionGraph	SchedulerBase.requestJob()
ArchivedExecutionGraph	SchedulerNG.requestJob()

Uses of ArchivedExecutionGraph in org.apache.flink.runtime.webmonitor

Methods in org.apache.flink.runtime.webmonitor that return types with arguments of type ArchivedExecutionGraph

Modifier and Type	Method and Description
CompletableFuture<ArchivedExecutionGraph>	RestfulGateway.requestJob(JobID jobId, Time timeout) Requests the ArchivedExecutionGraph for the given jobId.