|Modifier and Type||Method and Description|
Extracts maximum number of retained checkpoints configuration from the passed
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
config- The configuration that is accessed.
Loggerused for exposing the warning if the configured value is invalid.
public static <R extends ResourceVersion<R>> Collection<CompletedCheckpoint> retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore, CheckpointStoreUtil completedCheckpointStoreUtil) throws Exception
completed checkpointsfrom an
external store. This method is intended for retrieving an initial state of
R- Type of
checkpointStateHandleStore- Completed checkpoints in external store.
completedCheckpointStoreUtil- Utilities for completed checkpoint store.
Exception- If we're not able to fetch checkpoints for some reason.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.