Modifier and Type | Method and Description |
---|---|
static SavepointRestoreSettings |
CliFrontendParser.createSavepointRestoreSettings(org.apache.commons.cli.CommandLine commandLine) |
SavepointRestoreSettings |
ProgramOptions.getSavepointRestoreSettings() |
SavepointRestoreSettings |
ExecutionConfigAccessor.getSavepointRestoreSettings() |
Modifier and Type | Method and Description |
---|---|
SavepointRestoreSettings |
PackagedProgram.getSavepointSettings() |
Modifier and Type | Method and Description |
---|---|
PackagedProgram.Builder |
PackagedProgram.Builder.setSavepointRestoreSettings(SavepointRestoreSettings savepointRestoreSettings) |
Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointCoordinator.restoreSavepoint(SavepointRestoreSettings restoreSettings,
Map<JobVertexID,ExecutionJobVertex> tasks,
ClassLoader userClassLoader)
Restore the state with given savepoint.
|
Modifier and Type | Method and Description |
---|---|
static SavepointRestoreSettings |
SavepointRestoreSettings.forPath(String savepointPath) |
static SavepointRestoreSettings |
SavepointRestoreSettings.forPath(String savepointPath,
boolean allowNonRestoredState) |
static SavepointRestoreSettings |
SavepointRestoreSettings.forPath(String savepointPath,
boolean allowNonRestoredState,
RestoreMode restoreMode) |
static SavepointRestoreSettings |
SavepointRestoreSettings.fromConfiguration(ReadableConfig configuration) |
SavepointRestoreSettings |
JobGraph.getSavepointRestoreSettings()
Returns the configured savepoint restore setting.
|
static SavepointRestoreSettings |
SavepointRestoreSettings.none() |
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.setSavepointRestoreSettings(SavepointRestoreSettings settings)
Sets the savepoint restore settings.
|
JobGraphBuilder |
JobGraphBuilder.setSavepointRestoreSettings(SavepointRestoreSettings newSavepointRestoreSettings) |
static void |
SavepointRestoreSettings.toConfiguration(SavepointRestoreSettings savepointRestoreSettings,
Configuration configuration) |
Constructor and Description |
---|
RemoteStreamEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
String host,
int port,
Configuration clientConfiguration,
String[] jarFiles,
URL[] globalClasspaths,
SavepointRestoreSettings savepointRestoreSettings) |
RemoteStreamEnvironment(String host,
int port,
Configuration clientConfiguration,
String[] jarFiles,
URL[] globalClasspaths,
SavepointRestoreSettings savepointRestoreSettings)
Creates a new RemoteStreamEnvironment that points to the master (JobManager) described by the
given host name and port.
|
Modifier and Type | Method and Description |
---|---|
SavepointRestoreSettings |
StreamGraph.getSavepointRestoreSettings() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setSavepointRestoreSettings(SavepointRestoreSettings savepointRestoreSettings) |
void |
StreamGraphGenerator.setSavepointRestoreSettings(SavepointRestoreSettings savepointRestoreSettings) |
Constructor and Description |
---|
StreamGraph(ExecutionConfig executionConfig,
CheckpointConfig checkpointConfig,
SavepointRestoreSettings savepointRestoreSettings) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.