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

Packages that use ExecutionJobVertex

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmanager.web

Uses of ExecutionJobVertex in org.apache.flink.runtime.checkpoint

Method parameters in org.apache.flink.runtime.checkpoint with type arguments of type ExecutionJobVertex

Modifier and Type	Method and Description
void	CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks, boolean errorIfNoCheckpoint, boolean allOrNothingState)

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

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

Modifier and Type	Method and Description
ExecutionJobVertex	ExecutionVertex.getJobVertex()
ExecutionJobVertex	ExecutionGraph.getJobVertex(JobVertexID id)
ExecutionJobVertex	IntermediateResult.getProducer()

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

Modifier and Type	Method and Description
Map<JobVertexID,ExecutionJobVertex>	ExecutionGraph.getAllVertices()
Iterable<ExecutionJobVertex>	ExecutionGraph.getVerticesTopologically()

Method parameters in org.apache.flink.runtime.executiongraph with type arguments of type ExecutionJobVertex

Modifier and Type	Method and Description
void	ExecutionGraph.enableSnaphotCheckpointing(long interval, long checkpointTimeout, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, akka.actor.ActorSystem actorSystem)
void	ExecutionGraph.enableSnaphotCheckpointing(long interval, long checkpointTimeout, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, akka.actor.ActorSystem actorSystem)
void	ExecutionGraph.enableSnaphotCheckpointing(long interval, long checkpointTimeout, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, akka.actor.ActorSystem actorSystem)

Constructors in org.apache.flink.runtime.executiongraph with parameters of type ExecutionJobVertex

Constructor and Description
ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, scala.concurrent.duration.FiniteDuration timeout)
ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, scala.concurrent.duration.FiniteDuration timeout, long createTimestamp)
IntermediateResult(IntermediateDataSetID id, ExecutionJobVertex producer, int numParallelProducers, ResultPartitionType resultType)

Uses of ExecutionJobVertex in org.apache.flink.runtime.jobmanager.web

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

Modifier and Type	Method and Description
static String	JsonFactory.toJson(ExecutionJobVertex jobVertex)