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

Packages that use JobVertexID

Package	Description
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.deployment
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobmanager.scheduler
org.apache.flink.runtime.profiling.impl
org.apache.flink.runtime.profiling.impl.types
org.apache.flink.runtime.profiling.types
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.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(JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, Configuration jobConfiguration, Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber) Constructs a task deployment descriptor.
TaskDeploymentDescriptor(JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, Configuration jobConfiguration, Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, StateHandle operatorStates)

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	RuntimeEnvironment.getJobVertexId()
JobVertexID	Environment.getJobVertexId() Gets the ID of the jobVertex that this task corresponds to.

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)

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

Modifier and Type	Method and Description
void	ExecutionGraph.loadOperatorStates(Map<scala.Tuple3<JobVertexID,Integer,Long>,StateHandle> states)

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	AbstractJobVertex.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
AbstractJobVertex	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
AbstractJobVertex(String name, JobVertexID id) Constructs a new job vertex and assigns it with the given name.
InputFormatVertex(String name, JobVertexID id)

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)
int	SlotSharingGroupAssignment.getNumberOfAvailableSlotsForJid(JobVertexID jid)
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.profiling.impl

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

Constructor and Description
EnvironmentThreadSet(ThreadMXBean tmx, Thread mainThread, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId)

Uses of JobVertexID in org.apache.flink.runtime.profiling.impl.types

Methods in org.apache.flink.runtime.profiling.impl.types that return JobVertexID

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

Constructors in org.apache.flink.runtime.profiling.impl.types with parameters of type JobVertexID

Constructor and Description
InternalExecutionVertexProfilingData(JobID jobId, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId)
InternalExecutionVertexThreadProfilingData(JobID jobID, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, int userTime, int systemTime, int blockedTime, int waitedTime)

Uses of JobVertexID in org.apache.flink.runtime.profiling.types

Methods in org.apache.flink.runtime.profiling.types that return JobVertexID

Modifier and Type	Method and Description
JobVertexID	VertexProfilingEvent.getVertexID() Returns the ID of the vertex this profiling information belongs to.

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

Constructor and Description
ThreadProfilingEvent(int userTime, int systemTime, int blockedTime, int waitedTime, JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, JobID jobID, long timestamp, long profilingTimestamp)
VertexProfilingEvent(JobVertexID vertexId, int subtask, ExecutionAttemptID executionId, int profilingInterval, JobID jobID, long timestamp, long profilingTimestamp)

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.getVertexID() Returns the ID of this task vertex.

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

Constructor and Description
Task(JobID jobId, JobVertexID vertexId, int taskIndex, int parallelism, ExecutionAttemptID executionId, String taskName, akka.actor.ActorRef taskManager)
TaskInputSplitProvider(akka.actor.ActorRef jobManager, JobID jobId, JobVertexID vertexId, ExecutionAttemptID executionID, ClassLoader userCodeClassLoader, akka.util.Timeout timeout)