Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCompletedCheckpointStore<R extends ResourceVersion<R>>
Default implementation of
CompletedCheckpointStore . |
class |
EmbeddedCompletedCheckpointStore
An embedded in-memory checkpoint store, which supports shutdown and suspend.
|
class |
StandaloneCompletedCheckpointStore
CompletedCheckpointStore for JobManagers running in HighAvailabilityMode.NONE . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.