Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.zookeeper |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesStateHandleStore<T extends Serializable>
Class which stores state via the provided
RetrievableStateStorageHelper and writes the
returned state handle to ConfigMap. |
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 . |
Constructor and Description |
---|
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
StateHandleStore<CompletedCheckpoint,R> stateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil,
Collection<CompletedCheckpoint> completedCheckpoints,
SharedStateRegistry sharedStateRegistry,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance. |
Constructor and Description |
---|
DefaultJobGraphStore(StateHandleStore<JobGraph,R> stateHandleStore,
JobGraphStoreWatcher jobGraphStoreWatcher,
JobGraphStoreUtil jobGraphStoreUtil) |
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperStateHandleStore<T extends Serializable>
Class which stores state via the provided
RetrievableStateStorageHelper and writes the
returned state handle to ZooKeeper. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.