public class DefaultCompletedCheckpointStoreUtils extends Object
DefaultCompletedCheckpointStore
.Modifier and Type | Method and Description |
---|---|
static int |
getMaximumNumberOfRetainedCheckpoints(Configuration config,
org.slf4j.Logger logger)
Extracts maximum number of retained checkpoints configuration from the passed
Configuration . |
static <R extends ResourceVersion<R>> |
retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil)
Fetch all
completed checkpoints from an external store . |
public static int getMaximumNumberOfRetainedCheckpoints(Configuration config, org.slf4j.Logger logger)
Configuration
. The default value is used as a fallback if the passed value is a value larger
than 0
.config
- The configuration that is accessed.logger
- The Logger
used for exposing the warning if the configured value is
invalid.Configuration
.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.