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

Packages that use AccessExecutionJobVertex

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.job.metrics
org.apache.flink.runtime.webmonitor.stats
org.apache.flink.runtime.webmonitor.threadinfo

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

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

Modifier and Type	Class and Description
class	ArchivedExecutionJobVertex
class	ExecutionJobVertex An ExecutionJobVertex is part of the ExecutionGraph, and the peer to the JobVertex.
class	SpeculativeExecutionJobVertex The ExecutionJobVertex which supports speculative execution.

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

Modifier and Type	Method and Description
AccessExecutionJobVertex	AccessExecutionGraph.getJobVertex(JobVertexID id) Returns the job vertex for the given JobVertexID.

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

Modifier and Type	Method and Description
Map<JobVertexID,AccessExecutionJobVertex>	ArchivedExecutionGraph.getAllVertices()
Map<JobVertexID,? extends AccessExecutionJobVertex>	AccessExecutionGraph.getAllVertices() Returns a map containing all job vertices for this execution graph.
Iterable<? extends AccessExecutionJobVertex>	AccessExecutionGraph.getVerticesTopologically() Returns an iterable containing all job vertices for this execution graph in the order they were created.

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

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

Modifier and Type	Method and Description
protected abstract R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex) Called for each request after the corresponding AccessExecutionJobVertex has been retrieved from the AccessExecutionGraph.
protected VertexFlameGraph	JobVertexFlameGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected JobVertexAccumulatorsInfo	JobVertexAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected SubtasksAllAccumulatorsInfo	SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected SubtasksTimesInfo	SubtasksTimesHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)

Uses of AccessExecutionJobVertex in org.apache.flink.runtime.rest.handler.job.metrics

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

Modifier and Type	Method and Description
protected MetricCollectionResponseBody	JobVertexWatermarksHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)

Uses of AccessExecutionJobVertex in org.apache.flink.runtime.webmonitor.stats

Methods in org.apache.flink.runtime.webmonitor.stats with parameters of type AccessExecutionJobVertex

Modifier and Type	Method and Description
Optional<T>	VertexStatsTracker.getExecutionVertexStats(JobID jobId, AccessExecutionJobVertex vertex, int subtaskIndex) Returns statistics for a execution vertex.
Optional<T>	VertexStatsTracker.getJobVertexStats(JobID jobId, AccessExecutionJobVertex vertex) Returns statistics for a job vertex.

Uses of AccessExecutionJobVertex in org.apache.flink.runtime.webmonitor.threadinfo

Methods in org.apache.flink.runtime.webmonitor.threadinfo with parameters of type AccessExecutionJobVertex

Modifier and Type	Method and Description
Optional<VertexThreadInfoStats>	VertexThreadInfoTracker.getExecutionVertexStats(JobID jobId, AccessExecutionJobVertex vertex, int subtaskIndex)
Optional<VertexThreadInfoStats>	VertexThreadInfoTracker.getJobVertexStats(JobID jobId, AccessExecutionJobVertex vertex)