Modifier and Type | Method and Description |
---|---|
ExecutionGraphInfo |
ExecutionGraphInfoStore.get(JobID jobId)
Get the
ExecutionGraphInfo for the given job id. |
ExecutionGraphInfo |
MemoryExecutionGraphInfoStore.get(JobID jobId) |
ExecutionGraphInfo |
FileExecutionGraphInfoStore.get(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionGraphInfo> |
Dispatcher.requestExecutionGraphInfo(JobID jobId,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
VoidHistoryServerArchivist.archiveExecutionGraph(ExecutionGraphInfo executionGraph) |
CompletableFuture<Acknowledge> |
HistoryServerArchivist.archiveExecutionGraph(ExecutionGraphInfo executionGraphInfo)
Archives the given
ExecutionGraphInfo on the history server. |
protected org.apache.flink.runtime.dispatcher.Dispatcher.CleanupJobState |
Dispatcher.jobReachedTerminalState(ExecutionGraphInfo executionGraphInfo) |
protected org.apache.flink.runtime.dispatcher.Dispatcher.CleanupJobState |
MiniDispatcher.jobReachedTerminalState(ExecutionGraphInfo executionGraphInfo) |
void |
ExecutionGraphInfoStore.put(ExecutionGraphInfo executionGraphInfo)
Store the given
ExecutionGraphInfo in the store. |
void |
MemoryExecutionGraphInfoStore.put(ExecutionGraphInfo serializableExecutionGraphInfo) |
void |
FileExecutionGraphInfoStore.put(ExecutionGraphInfo executionGraphInfo) |
Modifier and Type | Method and Description |
---|---|
void |
OnCompletionActions.jobReachedGloballyTerminalState(ExecutionGraphInfo executionGraphInfo)
Job reached a globally terminal state.
|
Modifier and Type | Method and Description |
---|---|
ExecutionGraphInfo |
JobManagerRunnerResult.getExecutionGraphInfo() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionGraphInfo> |
JobManagerRunner.requestJob(Time timeout)
Requests the
ExecutionGraphInfo of the executed job. |
CompletableFuture<ExecutionGraphInfo> |
JobMasterServiceLeadershipRunner.requestJob(Time timeout) |
CompletableFuture<ExecutionGraphInfo> |
JobMasterGateway.requestJob(Time timeout)
Requests the
ExecutionGraphInfo of the executed job. |
CompletableFuture<ExecutionGraphInfo> |
JobMaster.requestJob(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static JobManagerRunnerResult |
JobManagerRunnerResult.forInitializationFailure(ExecutionGraphInfo executionGraphInfo,
Throwable failure) |
static JobManagerRunnerResult |
JobManagerRunnerResult.forSuccess(ExecutionGraphInfo executionGraphInfo) |
void |
DefaultJobMasterServiceProcess.jobReachedGloballyTerminalState(ExecutionGraphInfo executionGraphInfo) |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedJson> |
JobExceptionsHandler.archiveJsonWithPath(ExecutionGraphInfo executionGraphInfo) |
protected JobExceptionsInfoWithHistory |
JobExceptionsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobExceptionsMessageParameters> request,
ExecutionGraphInfo executionGraph) |
protected abstract R |
AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
ExecutionGraphInfo executionGraphInfo)
Called for each request after the corresponding
ExecutionGraphInfo has been retrieved
from the ExecutionGraphCache . |
protected R |
AbstractAccessExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
ExecutionGraphInfo executionGraphInfo) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionGraphInfo> |
ExecutionGraphCache.getExecutionGraphInfo(JobID jobId,
RestfulGateway restfulGateway)
Gets the
ExecutionGraphInfo for the given JobID and caches it. |
CompletableFuture<ExecutionGraphInfo> |
DefaultExecutionGraphCache.getExecutionGraphInfo(JobID jobId,
RestfulGateway restfulGateway) |
Modifier and Type | Method and Description |
---|---|
ExecutionGraphInfo |
SchedulerBase.requestJob() |
ExecutionGraphInfo |
SchedulerNG.requestJob() |
Modifier and Type | Method and Description |
---|---|
ExecutionGraphInfo |
AdaptiveScheduler.requestJob() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionGraphInfo> |
RestfulGateway.requestExecutionGraphInfo(JobID jobId,
Time timeout)
Requests the
ExecutionGraphInfo containing additional information besides the ArchivedExecutionGraph . |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedJson> |
WebMonitorEndpoint.archiveJsonWithPath(ExecutionGraphInfo executionGraphInfo) |
Modifier and Type | Method and Description |
---|---|
default Collection<ArchivedJson> |
OnlyExecutionGraphJsonArchivist.archiveJsonWithPath(ExecutionGraphInfo executionGraphInfo) |
Collection<ArchivedJson> |
JsonArchivist.archiveJsonWithPath(ExecutionGraphInfo executionGraphInfo)
Returns a
Collection of ArchivedJson s containing JSON responses and their
respective REST URL for a given job. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.