| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
BroadcastVariableKey.getVertexId() |
| Constructor and Description |
|---|
BroadcastVariableKey(JobVertexID vertexId,
String name,
int superstep) |
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
StateForTask.getOperatorId() |
| Modifier and Type | Method and Description |
|---|---|
void |
CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks,
boolean errorIfNoCheckpoint,
boolean allOrNothingState) |
| Constructor and Description |
|---|
StateForTask(SerializedValue<StateHandle<?>> state,
JobVertexID operatorId,
int subtask) |
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
TaskDeploymentDescriptor.getVertexID()
Returns the task's execution vertex ID.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
Environment.getJobVertexId()
Gets the ID of the JobVertex for which this task executes a parallel subtask.
|
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
ExecutionVertex.getJobvertexId() |
JobVertexID |
ExecutionJobVertex.getJobVertexId() |
| Modifier and Type | Method and Description |
|---|---|
Map<JobVertexID,ExecutionJobVertex> |
ExecutionGraph.getAllVertices() |
| Modifier and Type | Method and Description |
|---|---|
ExecutionJobVertex |
ExecutionGraph.getJobVertex(JobVertexID id) |
| Modifier and Type | Method and Description |
|---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
JobVertexID groupId) |
| Modifier and Type | Method and Description |
|---|---|
static JobVertexID |
JobVertexID.fromHexString(String hexString) |
JobVertexID |
JobVertex.getID()
Returns the ID of this job vertex.
|
| Modifier and Type | Method and Description |
|---|---|
JobVertex |
JobGraph.findVertexByID(JobVertexID id)
Searches for a vertex with a matching ID and returns it.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
List<JobVertexID> |
JobSnapshottingSettings.getVerticesToAcknowledge() |
List<JobVertexID> |
JobSnapshottingSettings.getVerticesToConfirm() |
List<JobVertexID> |
JobSnapshottingSettings.getVerticesToTrigger() |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
ScheduledUnit.getJobVertexId() |
| Modifier and Type | Method and Description |
|---|---|
Set<JobVertexID> |
SlotSharingGroup.getJobVertexIds() |
| Modifier and Type | Method and Description |
|---|---|
void |
SlotSharingGroup.addVertexToGroup(JobVertexID id) |
void |
SlotSharingGroup.removeVertexFromGroup(JobVertexID id) |
| Constructor and Description |
|---|
SlotSharingGroup(JobVertexID... sharedVertices) |
| Modifier and Type | Method and Description |
|---|---|
JobVertexID |
Task.getJobVertexId() |
JobVertexID |
RuntimeEnvironment.getJobVertexId() |
| 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) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.