Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.persistence |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCompletedCheckpointStore<R extends ResourceVersion<R>>
Default implementation of
CompletedCheckpointStore . |
Modifier and Type | Method and Description |
---|---|
static <R extends ResourceVersion<R>> |
DefaultCompletedCheckpointStoreUtils.retrieveCompletedCheckpoints(StateHandleStore<CompletedCheckpoint,R> checkpointStateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil)
Fetch all
completed checkpoints from an external store . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobGraphStore<R extends ResourceVersion<R>>
Default implementation for
JobGraphStore . |
Modifier and Type | Interface and Description |
---|---|
interface |
StateHandleStore<T extends Serializable,R extends ResourceVersion<R>>
Class which stores state via the provided
RetrievableStateStorageHelper and writes the
returned state handle to distributed coordination system(e.g. |
Modifier and Type | Class and Description |
---|---|
class |
IntegerResourceVersion
ResourceVersion implementation with Integer value. |
class |
StringResourceVersion
ResourceVersion implementation with String value. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.