public class PerJobCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
CheckpointRecoveryFactory
which creates and keeps separate CompletedCheckpointStore
and CheckpointIDCounter
for each JobID
.Constructor and Description |
---|
PerJobCheckpointRecoveryFactory(java.util.function.Function<Integer,CompletedCheckpointStore> completedCheckpointStorePerJobFactory,
java.util.function.Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory) |
Modifier and Type | Method and Description |
---|---|
CheckpointIDCounter |
createCheckpointIDCounter(JobID jobId)
Creates a
CheckpointIDCounter instance for a job. |
CompletedCheckpointStore |
createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader)
Creates a
CompletedCheckpointStore instance for a job. |
static CheckpointRecoveryFactory |
useSameServicesForAllJobs(CompletedCheckpointStore store,
CheckpointIDCounter counter) |
public PerJobCheckpointRecoveryFactory(java.util.function.Function<Integer,CompletedCheckpointStore> completedCheckpointStorePerJobFactory, java.util.function.Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory)
public CompletedCheckpointStore createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader)
CheckpointRecoveryFactory
CompletedCheckpointStore
instance for a job.createCheckpointStore
in interface CheckpointRecoveryFactory
jobId
- Job ID to recover checkpoints formaxNumberOfCheckpointsToRetain
- Maximum number of checkpoints to retainuserClassLoader
- User code class loader of the jobCompletedCheckpointStore
instance for the jobpublic CheckpointIDCounter createCheckpointIDCounter(JobID jobId)
CheckpointRecoveryFactory
CheckpointIDCounter
instance for a job.createCheckpointIDCounter
in interface CheckpointRecoveryFactory
jobId
- Job ID to recover checkpoints forCheckpointIDCounter
instance for the job@VisibleForTesting public static CheckpointRecoveryFactory useSameServicesForAllJobs(CompletedCheckpointStore store, CheckpointIDCounter counter)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.