public class SavepointStoreFactory extends Object
SavepointStore
instances.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_SAVEPOINT_BACKEND |
static org.slf4j.Logger |
LOG |
static String |
SAVEPOINT_BACKEND_KEY |
static String |
SAVEPOINT_DIRECTORY_KEY |
Constructor and Description |
---|
SavepointStoreFactory() |
Modifier and Type | Method and Description |
---|---|
static SavepointStore |
createFromConfig(Configuration config)
Creates a
SavepointStore from the specified Configuration. |
public static final String SAVEPOINT_BACKEND_KEY
public static final String SAVEPOINT_DIRECTORY_KEY
public static final String DEFAULT_SAVEPOINT_BACKEND
public static final org.slf4j.Logger LOG
public static SavepointStore createFromConfig(Configuration config) throws Exception
SavepointStore
from the specified Configuration.
You can configure a savepoint-specific backend for the savepoints. If you don't configure anything, the regular checkpoint backend will be used.
The default and fallback backend is the job manager, which loses the savepoint after the job manager shuts down.
config
- The configuration to parse the savepoint backend configuration.Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.