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.executiongraph.failover
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.query
org.apache.flink.runtime.rest.handler.legacy.backpressure
org.apache.flink.runtime.scheduler

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

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

Modifier and Type	Method and Description
void	StateAssignmentOperation.checkParallelismPreconditions(List<OperatorState> operatorStates, ExecutionJobVertex executionJobVertex)

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

Modifier and Type	Method and Description
static CompletedCheckpoint	Checkpoints.loadAndValidateCheckpoint(JobID jobId, Map<JobVertexID,ExecutionJobVertex> tasks, CompletedCheckpointStorageLocation location, ClassLoader classLoader, boolean allowNonRestoredState)
boolean	CheckpointCoordinator.restoreInitialCheckpointIfPresent(Set<ExecutionJobVertex> tasks) Restores the latest checkpointed at the beginning of the job execution.
boolean	CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks, boolean errorIfNoCheckpoint, boolean allowNonRestoredState) Deprecated.
boolean	CheckpointCoordinator.restoreLatestCheckpointedStateToAll(Set<ExecutionJobVertex> tasks, boolean allowNonRestoredState) Restores the latest checkpointed state to all tasks and all coordinators.
OptionalLong	CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks(Set<ExecutionJobVertex> tasks) Restores the latest checkpointed state to a set of subtasks.
boolean	CheckpointCoordinator.restoreSavepoint(String savepointPointer, boolean allowNonRestored, Map<JobVertexID,ExecutionJobVertex> tasks, ClassLoader userClassLoader) Restore the state with given savepoint.

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

Constructor and Description
CheckpointStatsTracker(int numRememberedCheckpoints, List<ExecutionJobVertex> jobVertices, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, MetricGroup metricGroup) Creates a new checkpoint stats tracker.
StateAssignmentOperation(long restoreCheckpointId, Set<ExecutionJobVertex> tasks, Map<OperatorID,OperatorState> operatorStates, boolean allowNonRestoredState)

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.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, List<MasterTriggerRestoreHook<?>> masterHooks, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore checkpointStore, StateBackend checkpointStateBackend, CheckpointStatsTracker statsTracker)
void	ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, List<MasterTriggerRestoreHook<?>> masterHooks, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore checkpointStore, StateBackend checkpointStateBackend, CheckpointStatsTracker statsTracker)
void	ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, List<MasterTriggerRestoreHook<?>> masterHooks, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore checkpointStore, StateBackend checkpointStateBackend, CheckpointStatsTracker statsTracker)

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

Constructor and Description
ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex)
ExecutionVertex(ExecutionJobVertex jobVertex, int subTaskIndex, IntermediateResult[] producedDataSets, Time timeout, long initialGlobalModVersion, long createTimestamp, int maxPriorExecutionHistoryLength) Creates an ExecutionVertex.
IntermediateResult(IntermediateDataSetID id, ExecutionJobVertex producer, int numParallelProducers, ResultPartitionType resultType)

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

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

Modifier and Type	Method and Description
abstract void	FailoverStrategy.notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological) Called whenever new vertices are added to the ExecutionGraph.
void	NoOpFailoverStrategy.notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological)
void	RestartAllStrategy.notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological)

Uses of ExecutionJobVertex in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination with parameters of type ExecutionJobVertex

Modifier and Type	Method and Description
static OperatorCoordinatorHolder	OperatorCoordinatorHolder.create(SerializedValue<OperatorCoordinator.Provider> serializedProvider, ExecutionJobVertex jobVertex, ClassLoader classLoader)

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

Constructor parameters in org.apache.flink.runtime.query with type arguments of type ExecutionJobVertex

Constructor and Description
KvStateLocationRegistry(JobID jobId, Map<JobVertexID,ExecutionJobVertex> jobVertices) Creates the registry for the job.

Uses of ExecutionJobVertex in org.apache.flink.runtime.rest.handler.legacy.backpressure

Methods in org.apache.flink.runtime.rest.handler.legacy.backpressure with parameters of type ExecutionJobVertex

Modifier and Type	Method and Description
Optional<OperatorBackPressureStats>	BackPressureStatsTrackerImpl.getOperatorBackPressureStats(ExecutionJobVertex vertex) Returns back pressure statistics for a operator.
Optional<OperatorBackPressureStats>	BackPressureStatsTracker.getOperatorBackPressureStats(ExecutionJobVertex vertex) Returns back pressure statistics for an operator.

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

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

Modifier and Type	Method and Description
ExecutionJobVertex	SchedulerBase.getExecutionJobVertex(JobVertexID jobVertexId)