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 |
TaskStateStats.getJobVertexId() |
JobVertexID |
TaskState.getJobVertexID()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TaskStateStats |
AbstractCheckpointStats.getTaskStateStats(JobVertexID jobVertexId)
Returns the task state stats for the given job vertex ID or
null if no task with
such an ID is available. |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpoint |
Checkpoints.loadAndValidateCheckpoint(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> tasks,
CompletedCheckpointStorageLocation location,
ClassLoader classLoader,
boolean allowNonRestoredState) |
boolean |
CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID,ExecutionJobVertex> tasks,
boolean errorIfNoCheckpoint,
boolean allowNonRestoredState)
Deprecated.
|
boolean |
CheckpointCoordinator.restoreSavepoint(String savepointPointer,
boolean allowNonRestored,
Map<JobVertexID,ExecutionJobVertex> tasks,
ClassLoader userClassLoader)
Restore the state with given savepoint.
|
Constructor and Description |
---|
TaskState(JobVertexID jobVertexID,
int parallelism,
int maxParallelism,
int chainLength)
Deprecated.
|
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 |
AccessExecutionJobVertex.getJobVertexId()
Returns the
JobVertexID for this job vertex. |
JobVertexID |
ExecutionJobVertex.getJobVertexId() |
JobVertexID |
TaskInformation.getJobVertexId() |
JobVertexID |
ArchivedExecutionJobVertex.getJobVertexId() |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,ExecutionJobVertex> |
DefaultExecutionGraph.getAllVertices() |
Map<JobVertexID,AccessExecutionJobVertex> |
ArchivedExecutionGraph.getAllVertices() |
Map<JobVertexID,? extends AccessExecutionJobVertex> |
AccessExecutionGraph.getAllVertices()
Returns a map containing all job vertices for this execution graph.
|
Map<JobVertexID,ExecutionJobVertex> |
ExecutionGraph.getAllVertices() |
Modifier and Type | Method and Description |
---|---|
SubtaskAttemptNumberStore |
DefaultVertexAttemptNumberStore.getAttemptCounts(JobVertexID vertexId) |
SubtaskAttemptNumberStore |
VertexAttemptNumberStore.getAttemptCounts(JobVertexID vertexId)
Returns the attempt numbers for the given vertex.
|
ExecutionJobVertex |
DefaultExecutionGraph.getJobVertex(JobVertexID id) |
ArchivedExecutionJobVertex |
ArchivedExecutionGraph.getJobVertex(JobVertexID id) |
AccessExecutionJobVertex |
AccessExecutionGraph.getJobVertex(JobVertexID id)
Returns the job vertex for the given
JobVertexID . |
ExecutionJobVertex |
ExecutionGraph.getJobVertex(JobVertexID id) |
void |
MutableVertexAttemptNumberStore.setAttemptCount(JobVertexID jobVertexId,
int subtaskIndex,
int attemptNumber)
Sets the attempt count for the given subtask of the given vertex.
|
void |
DefaultVertexAttemptNumberStore.setAttemptCount(JobVertexID jobVertexId,
int subtaskIndex,
int attemptNumber) |
Constructor and Description |
---|
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
ResourceProfile resourceProfile,
StringifiedAccumulatorResult[] archivedUserAccumulators) |
TaskInformation(JobVertexID jobVertexId,
String taskName,
int numberOfSubtasks,
int maxNumberOfSubtasks,
String invokableClassName,
Configuration taskConfiguration) |
Constructor and Description |
---|
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
ErrorInfo failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
CheckpointStatsSnapshot checkpointStatsSnapshot,
String stateBackendName,
String checkpointStorageName) |
Modifier and Type | Method and Description |
---|---|
static JobVertexID |
JobVertexID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
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.
|
static OperatorID |
OperatorID.fromJobVertexID(JobVertexID id) |
Constructor and Description |
---|
InputOutputFormatVertex(String name,
JobVertexID id,
List<OperatorIDPair> operatorIDPairs) |
JobVertex(String name,
JobVertexID id)
Constructs a new job vertex and assigns it with the given name.
|
JobVertex(String name,
JobVertexID primaryId,
List<OperatorIDPair> operatorIDPairs)
Constructs a new job vertex and assigns it with the given name.
|
Modifier and Type | Method and Description |
---|---|
JobVertexID |
DefaultLogicalVertex.getId() |
Modifier and Type | Method and Description |
---|---|
Set<JobVertexID> |
DefaultLogicalPipelinedRegion.getVertexIDs() |
Modifier and Type | Method and Description |
---|---|
Set<JobVertexID> |
SlotSharingGroup.getJobVertexIds() |
List<JobVertexID> |
CoLocationGroup.getVertexIds()
Returns the IDs of the
JobVertex instances participating in this group. |
List<JobVertexID> |
CoLocationGroupImpl.getVertexIds() |
Modifier and Type | Method and Description |
---|---|
void |
SlotSharingGroup.addVertexToGroup(JobVertexID id) |
void |
SlotSharingGroup.removeVertexFromGroup(JobVertexID id) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
KvStateRegistryGateway.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress)
Notifies that queryable state has been registered.
|
CompletableFuture<Acknowledge> |
JobMaster.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
CompletableFuture<Acknowledge> |
KvStateRegistryGateway.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName)
Notifies that queryable state has been unregistered.
|
CompletableFuture<Acknowledge> |
JobMaster.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
CompletableFuture<SerializedInputSplit> |
JobMasterGateway.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt)
Requests the next input split for the
ExecutionJobVertex . |
CompletableFuture<SerializedInputSplit> |
JobMaster.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Modifier and Type | Field and Description |
---|---|
protected JobVertexID |
TaskMetricGroup.vertexId |
Modifier and Type | Method and Description |
---|---|
TaskMetricGroup |
UnregisteredMetricGroups.UnregisteredTaskManagerJobMetricGroup.addTask(JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptID,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskMetricGroup |
TaskManagerJobMetricGroup.addTask(JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptID,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskMetricGroup |
UnregisteredMetricGroups.UnregisteredTaskManagerMetricGroup.addTaskForJob(JobID jobId,
String jobName,
JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptId,
String taskName,
int subtaskIndex,
int attemptNumber) |
TaskMetricGroup |
TaskManagerMetricGroup.addTaskForJob(JobID jobId,
String jobName,
JobVertexID jobVertexId,
ExecutionAttemptID executionAttemptId,
String taskName,
int subtaskIndex,
int attemptNumber) |
Constructor and Description |
---|
TaskMetricGroup(MetricRegistry registry,
TaskManagerJobMetricGroup parent,
JobVertexID vertexId,
ExecutionAttemptID executionId,
String taskName,
int subtaskIndex,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
KvStateLocation.getJobVertexId()
Returns the JobVertexID the KvState instances belong to.
|
Modifier and Type | Method and Description |
---|---|
TaskKvStateRegistry |
KvStateRegistry.createTaskRegistry(JobID jobId,
JobVertexID jobVertexId)
Creates a
TaskKvStateRegistry facade for the Task identified by the given
JobID and JobVertexID instance. |
void |
KvStateRegistryListener.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId)
Notifies the listener about a registered KvState instance.
|
void |
KvStateLocationRegistry.notifyKvStateRegistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress)
Notifies the registry about a registered KvState instance.
|
void |
KvStateRegistryListener.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName)
Notifies the listener about an unregistered KvState instance.
|
void |
KvStateLocationRegistry.notifyKvStateUnregistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName)
Notifies the registry about an unregistered KvState instance.
|
KvStateID |
KvStateRegistry.registerKvState(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
InternalKvState<?,?,?> kvState,
ClassLoader userClassLoader)
Registers the KvState instance and returns the assigned ID.
|
void |
KvStateRegistry.unregisterKvState(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId)
Unregisters the KvState instance identified by the given KvStateID.
|
Constructor and Description |
---|
KvStateLocation(JobID jobId,
JobVertexID jobVertexId,
int numKeyGroups,
String registrationName)
Creates the location information.
|
Constructor and Description |
---|
KvStateLocationRegistry(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> jobVertices)
Creates the registry for the job.
|
Modifier and Type | Method and Description |
---|---|
protected JobVertexID |
JobVertexIdPathParameter.convertFromString(String value) |
Modifier and Type | Method and Description |
---|---|
protected String |
JobVertexIdPathParameter.convertToString(JobVertexID value) |
Constructor and Description |
---|
JobVertexDetailsInfo(JobVertexID id,
String name,
int parallelism,
int maxParallelism,
long now,
List<SubtaskExecutionAttemptDetailsInfo> subtasks) |
JobVertexTaskManagersInfo(JobVertexID jobVertexID,
String name,
long now,
Collection<JobVertexTaskManagersInfo.TaskManagersInfo> taskManagerInfos) |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,TaskCheckpointStatistics> |
CheckpointStatistics.getCheckpointStatisticsPerTask() |
Constructor and Description |
---|
CompletedCheckpointStatistics(long id,
CheckpointStatsStatus status,
boolean savepoint,
long triggerTimestamp,
long latestAckTimestamp,
long stateSize,
long duration,
long alignmentBuffered,
long processedData,
long persistedData,
int numSubtasks,
int numAckSubtasks,
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType,
Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask,
String externalPath,
boolean discarded) |
FailedCheckpointStatistics(long id,
CheckpointStatsStatus status,
boolean savepoint,
long triggerTimestamp,
long latestAckTimestamp,
long stateSize,
long duration,
long alignmentBuffered,
long processedData,
long persistedData,
int numSubtasks,
int numAckSubtasks,
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType,
Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask,
long failureTimestamp,
String failureMessage) |
PendingCheckpointStatistics(long id,
CheckpointStatsStatus status,
boolean savepoint,
long triggerTimestamp,
long latestAckTimestamp,
long stateSize,
long duration,
long alignmentBuffered,
long processedData,
long persistedData,
int numSubtasks,
int numAckSubtasks,
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType,
Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
JobDetailsInfo.JobVertexDetailsInfo.getJobVertexID() |
Modifier and Type | Method and Description |
---|---|
static SubtaskExecutionAttemptDetailsInfo |
SubtaskExecutionAttemptDetailsInfo.create(AccessExecution execution,
MetricFetcher metricFetcher,
JobID jobID,
JobVertexID jobVertexID) |
Constructor and Description |
---|
JobVertexDetailsInfo(JobVertexID jobVertexID,
String name,
int maxParallelism,
int parallelism,
ExecutionState executionState,
long startTime,
long endTime,
long duration,
Map<ExecutionState,Integer> tasksPerState,
IOMetricsInfo jobVertexMetrics) |
SubtasksAllAccumulatorsInfo(JobVertexID jobVertexId,
int parallelism,
Collection<SubtasksAllAccumulatorsInfo.SubtaskAccumulatorsInfo> subtaskAccumulatorsInfos) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
JobVertexIDDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser p,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
void |
JobVertexIDKeySerializer.serialize(JobVertexID value,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator gen,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider provider) |
void |
JobVertexIDSerializer.serialize(JobVertexID value,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator gen,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider provider) |
Modifier and Type | Method and Description |
---|---|
ExecutionJobVertex |
SchedulerBase.getExecutionJobVertex(JobVertexID jobVertexId) |
VertexParallelismInformation |
VertexParallelismStore.getParallelismInfo(JobVertexID vertexId)
Returns a given vertex's parallelism information.
|
VertexParallelismInformation |
DefaultVertexParallelismStore.getParallelismInfo(JobVertexID vertexId) |
void |
SchedulerBase.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
KvStateHandler.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
SchedulerNG.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
SchedulerBase.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
void |
KvStateHandler.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
void |
SchedulerNG.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
SerializedInputSplit |
ExecutionGraphHandler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
SchedulerBase.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
SchedulerNG.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
void |
MutableVertexParallelismStore.setParallelismInfo(JobVertexID vertexId,
VertexParallelismInformation info)
Sets the parallelism properties for the given vertex.
|
void |
DefaultVertexParallelismStore.setParallelismInfo(JobVertexID vertexId,
VertexParallelismInformation info) |
Modifier and Type | Method and Description |
---|---|
JobInformation.VertexInformation |
JobGraphJobInformation.getVertexInformation(JobVertexID jobVertexId) |
void |
AdaptiveScheduler.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
AdaptiveScheduler.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
SerializedInputSplit |
AdaptiveScheduler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
JobInformation.VertexInformation.getJobVertexID() |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,Integer> |
VertexParallelismWithSlotSharing.getMaxParallelismForVertices() |
Map<JobVertexID,Integer> |
VertexParallelism.getMaxParallelismForVertices() |
Modifier and Type | Method and Description |
---|---|
int |
VertexParallelismWithSlotSharing.getParallelism(JobVertexID jobVertexId) |
int |
VertexParallelism.getParallelism(JobVertexID jobVertexId) |
JobInformation.VertexInformation |
JobInformation.getVertexInformation(JobVertexID jobVertexId) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
ExecutionVertexID.getJobVertexId() |
Constructor and Description |
---|
ExecutionVertexID(JobVertexID jobVertexId,
int subtaskIndex) |
Modifier and Type | Method and Description |
---|---|
TaskLocalStateStore |
TaskExecutorLocalStateStoresManager.localStateStoreForSubtask(JobID jobId,
AllocationID allocationID,
JobVertexID jobVertexID,
int subtaskIndex) |
Constructor and Description |
---|
LocalRecoveryDirectoryProviderImpl(File[] allocationBaseDirs,
JobID jobID,
JobVertexID jobVertexID,
int subtaskIndex) |
LocalRecoveryDirectoryProviderImpl(File allocationBaseDir,
JobID jobID,
JobVertexID jobVertexID,
int subtaskIndex) |
TaskLocalStateStoreImpl(JobID jobID,
AllocationID allocationID,
JobVertexID jobVertexID,
int subtaskIndex,
LocalRecoveryConfig localRecoveryConfig,
Executor discardExecutor) |
Modifier and Type | Method and Description |
---|---|
TaskKvStateRegistry |
KvStateService.createKvStateTaskRegistry(JobID jobId,
JobVertexID jobVertexId) |
Modifier and Type | Method and Description |
---|---|
void |
RpcKvStateRegistryListener.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId) |
void |
RpcKvStateRegistryListener.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
Constructor and Description |
---|
RpcInputSplitProvider(JobMasterGateway jobMasterGateway,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
RuntimeEnvironment.getJobVertexId() |
JobVertexID |
Task.getJobVertexId() |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
UserCodeClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
IndexedInputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorEventGateway,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask,
ExternalResourceInfoProvider externalResourceInfoProvider) |
Modifier and Type | Method and Description |
---|---|
JobVertexID |
SavepointEnvironment.getJobVertexId() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.