Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesCheckpointStoreUtil
Singleton
CheckpointStoreUtil implementation for Kubernetes. |
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperCheckpointStoreUtil
Singleton
CheckpointStoreUtil implementation for ZooKeeper. |
Constructor and Description |
---|
DefaultCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain,
StateHandleStore<CompletedCheckpoint,R> stateHandleStore,
CheckpointStoreUtil completedCheckpointStoreUtil,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.