Uses of Class
org.apache.flink.runtime.jobgraph.JobVertexID

Packages that use JobVertexID

Package	Description
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.instance
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager.scheduler
org.apache.flink.runtime.taskmanager

Uses of JobVertexID in org.apache.flink.runtime.broadcast

Methods in org.apache.flink.runtime.broadcast that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	BroadcastVariableKey.getVertexId()

Constructors in org.apache.flink.runtime.broadcast with parameters of type JobVertexID

Constructor and Description
BroadcastVariableKey(JobVertexID vertexId, String name, int superstep)

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

Methods in org.apache.flink.runtime.checkpoint that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	StateForTask.getOperatorId()

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

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

Constructors in org.apache.flink.runtime.checkpoint with parameters of type JobVertexID

Constructor and Description
StateForTask(SerializedValue<StateHandle<?>> state, JobVertexID operatorId, int subtask)

Uses of JobVertexID in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	TaskDeploymentDescriptor.getVertexID() Returns the task's execution vertex ID.

Constructors in org.apache.flink.runtime.deployment with parameters of type JobVertexID

Constructor and Description
TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber)
TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, SerializedValue<StateHandle<?>> operatorState) Constructs a task deployment descriptor.

Uses of JobVertexID in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	Environment.getJobVertexId() Gets the ID of the JobVertex for which this task executes a parallel subtask.

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

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

Modifier and Type	Method and Description
JobVertexID	ExecutionVertex.getJobvertexId()
JobVertexID	ExecutionJobVertex.getJobVertexId()

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

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

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

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

Uses of JobVertexID in org.apache.flink.runtime.instance

Methods in org.apache.flink.runtime.instance with parameters of type JobVertexID

Modifier and Type	Method and Description
SimpleSlot	SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot, Locality locality, JobVertexID groupId)

Uses of JobVertexID in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return JobVertexID

Modifier and Type	Method and Description
static JobVertexID	JobVertexID.fromHexString(String hexString)
JobVertexID	JobVertex.getID() Returns the ID of this job vertex.

Methods in org.apache.flink.runtime.jobgraph with parameters of type JobVertexID

Modifier and Type	Method and Description
JobVertex	JobGraph.findVertexByID(JobVertexID id) Searches for a vertex with a matching ID and returns it.

Constructors in org.apache.flink.runtime.jobgraph with parameters of type JobVertexID

Constructor and Description
InputFormatVertex(String name, JobVertexID id)
JobVertex(String name, JobVertexID id) Constructs a new job vertex and assigns it with the given name.

Uses of JobVertexID in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks that return types with arguments of type JobVertexID

Modifier and Type	Method and Description
List<JobVertexID>	JobSnapshottingSettings.getVerticesToAcknowledge()
List<JobVertexID>	JobSnapshottingSettings.getVerticesToConfirm()
List<JobVertexID>	JobSnapshottingSettings.getVerticesToTrigger()

Constructor parameters in org.apache.flink.runtime.jobgraph.tasks with type arguments of type JobVertexID

Constructor and Description
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout)
JobSnapshottingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout)

Uses of JobVertexID in org.apache.flink.runtime.jobmanager.scheduler

Methods in org.apache.flink.runtime.jobmanager.scheduler that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	ScheduledUnit.getJobVertexId()

Methods in org.apache.flink.runtime.jobmanager.scheduler that return types with arguments of type JobVertexID

Modifier and Type	Method and Description
Set<JobVertexID>	SlotSharingGroup.getJobVertexIds()

Methods in org.apache.flink.runtime.jobmanager.scheduler with parameters of type JobVertexID

Modifier and Type	Method and Description
void	SlotSharingGroup.addVertexToGroup(JobVertexID id)
void	SlotSharingGroup.removeVertexFromGroup(JobVertexID id)

Constructors in org.apache.flink.runtime.jobmanager.scheduler with parameters of type JobVertexID

Constructor and Description
SlotSharingGroup(JobVertexID... sharedVertices)

Uses of JobVertexID in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	Task.getJobVertexId()
JobVertexID	RuntimeEnvironment.getJobVertexId()

Constructors in org.apache.flink.runtime.taskmanager with parameters of type JobVertexID

Constructor and Description
RuntimeEnvironment(org.apache.flink.api.common.JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, String taskName, String taskNameWithSubtasks, int subtaskIndex, int parallelism, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, ClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, InputSplitProvider splitProvider, Map<String,Future<org.apache.flink.core.fs.Path>> distCacheEntries, ResultPartitionWriter[] writers, InputGate[] inputGates, akka.actor.ActorRef jobManagerActor)
TaskInputSplitProvider(akka.actor.ActorRef jobManager, org.apache.flink.api.common.JobID jobId, JobVertexID vertexId, ExecutionAttemptID executionID, ClassLoader userCodeClassLoader, akka.util.Timeout timeout)