public class DefaultCompletedCheckpointStoreUtils extends Object
DefaultCompletedCheckpointStore
.Modifier and Type | Method and Description |
---|---|
static <R extends ResourceVersion<R>> |
retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil)
Fetch all
completed checkpoints from an external store . |
public static <R extends ResourceVersion<R>> Collection<CompletedCheckpoint> retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore, CheckpointStoreUtil completedCheckpointStoreUtil) throws Exception
completed checkpoints
from an external store
. This method is intended for retrieving an initial state of DefaultCompletedCheckpointStore
.R
- Type of ResourceVersion
checkpointStateHandleStore
- Completed checkpoints in external store.completedCheckpointStoreUtil
- Utilities for completed checkpoint store.completed checkpoints
.Exception
- If we're not able to fetch checkpoints for some reason.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.