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 and Description |
---|
DefaultCheckpointPlanCalculator(JobID jobId,
CheckpointPlanCalculatorContext context,
Iterable<ExecutionJobVertex> jobVerticesInTopologyOrderIterable) |
StateAssignmentOperation(long restoreCheckpointId,
Set<ExecutionJobVertex> tasks,
Map<OperatorID,OperatorState> operatorStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
ExecutionJobVertex |
ExecutionVertex.getJobVertex() |
ExecutionJobVertex |
DefaultExecutionGraph.getJobVertex(JobVertexID id) |
ExecutionJobVertex |
ExecutionGraph.getJobVertex(JobVertexID id) |
ExecutionJobVertex |
IntermediateResult.getProducer() |
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,ExecutionJobVertex> |
DefaultExecutionGraph.getAllVertices() |
Map<JobVertexID,ExecutionJobVertex> |
ExecutionGraph.getAllVertices() |
Iterable<ExecutionJobVertex> |
DefaultExecutionGraph.getVerticesTopologically() |
Iterable<ExecutionJobVertex> |
ExecutionGraph.getVerticesTopologically() |
Constructor and Description |
---|
ArchivedExecutionJobVertex(ExecutionJobVertex jobVertex) |
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long createTimestamp,
int maxPriorExecutionHistoryLength,
int initialAttemptCount)
Creates an ExecutionVertex.
|
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
Modifier and Type | Method and Description |
---|---|
static OperatorCoordinatorHolder |
OperatorCoordinatorHolder.create(SerializedValue<OperatorCoordinator.Provider> serializedProvider,
ExecutionJobVertex jobVertex,
ClassLoader classLoader) |
Constructor and Description |
---|
KvStateLocationRegistry(JobID jobId,
Map<JobVertexID,ExecutionJobVertex> jobVertices)
Creates the registry for the job.
|
Modifier and Type | Method and Description |
---|---|
ExecutionJobVertex |
SchedulerBase.getExecutionJobVertex(JobVertexID jobVertexId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.