Uses of Interface
org.apache.flink.runtime.executiongraph.AccessExecution

Packages that use AccessExecution

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.util
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.scheduler.exceptionhistory

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

Classes in org.apache.flink.runtime.executiongraph that implement AccessExecution

Modifier and Type	Class and Description
class	ArchivedExecution ArchivedExecution is a readonly representation of Execution.
class	Execution A single execution of a vertex.

Methods in org.apache.flink.runtime.executiongraph with type parameters of type AccessExecution

Modifier and Type	Method and Description
<T extends AccessExecution> Collection<T>	AccessExecutionVertex.getCurrentExecutions() Returns the current executions for this execution vertex.

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

Modifier and Type	Method and Description
AccessExecution	AccessExecutionVertex.getCurrentExecutionAttempt() Returns the current execution for this execution vertex.

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type AccessExecution

Modifier and Type	Method and Description
Optional<AccessExecution>	DefaultExecutionGraph.findExecution(ExecutionAttemptID attemptId)
Optional<AccessExecution>	ExecutionGraph.findExecution(ExecutionAttemptID attemptId)
Collection<AccessExecution>	ArchivedExecutionVertex.getCurrentExecutions()

Uses of AccessExecution in org.apache.flink.runtime.rest.handler.job

Methods in org.apache.flink.runtime.rest.handler.job with parameters of type AccessExecution

Modifier and Type	Method and Description
protected SubtaskExecutionAttemptAccumulatorsInfo	SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)
protected abstract R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution) Called for each request after the corresponding AccessExecution has been retrieved from the AccessExecutionVertex.
protected SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)

Uses of AccessExecution in org.apache.flink.runtime.rest.handler.util

Methods in org.apache.flink.runtime.rest.handler.util with parameters of type AccessExecution

Modifier and Type	Method and Description
void	MutableIOMetrics.addIOMetrics(AccessExecution attempt, MetricFetcher fetcher, String jobID, String taskID) Adds the IO metrics for the given attempt to this object.

Uses of AccessExecution in org.apache.flink.runtime.rest.messages.job

Methods in org.apache.flink.runtime.rest.messages.job with parameters of type AccessExecution

Modifier and Type	Method and Description
static SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsInfo.create(AccessExecution execution, MetricFetcher metricFetcher, JobID jobID, JobVertexID jobVertexID, List<SubtaskExecutionAttemptDetailsInfo> otherConcurrentAttempts)
static Map<ExecutionState,Long>	StatusDurationUtils.getExecutionStateDuration(AccessExecution execution)

Uses of AccessExecution in org.apache.flink.runtime.scheduler.exceptionhistory

Methods in org.apache.flink.runtime.scheduler.exceptionhistory with parameters of type AccessExecution

Modifier and Type	Method and Description
static ExceptionHistoryEntry	ExceptionHistoryEntry.create(AccessExecution failedExecution, String taskName) Creates an ExceptionHistoryEntry based on the provided Execution.