Package | Description |
---|---|
org.apache.flink.client.cli | |
org.apache.flink.client.program | |
org.apache.flink.runtime.jobgraph |
Modifier and Type | Method and Description |
---|---|
SavepointRestoreSettings |
ProgramOptions.getSavepointRestoreSettings() |
Modifier and Type | Field and Description |
---|---|
protected SavepointRestoreSettings |
ContextEnvironment.savepointSettings |
Modifier and Type | Method and Description |
---|---|
SavepointRestoreSettings |
ContextEnvironment.getSavepointRestoreSettings() |
SavepointRestoreSettings |
PackagedProgram.getSavepointSettings() |
Modifier and Type | Method and Description |
---|---|
static JobGraph |
ClusterClient.getJobGraph(Configuration flinkConfig,
FlinkPlan optPlan,
List<URL> jarFiles,
List<URL> classpaths,
SavepointRestoreSettings savepointSettings) |
static JobGraph |
ClusterClient.getJobGraph(Configuration flinkConfig,
PackagedProgram prog,
FlinkPlan optPlan,
SavepointRestoreSettings savepointSettings) |
JobSubmissionResult |
ClusterClient.run(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader,
SavepointRestoreSettings savepointSettings) |
JobSubmissionResult |
ClusterClient.run(JobWithJars jobWithJars,
int parallelism,
SavepointRestoreSettings savepointSettings)
Runs a program on the Flink cluster to which this client is connected.
|
void |
PackagedProgram.setSavepointRestoreSettings(SavepointRestoreSettings savepointSettings) |
Constructor and Description |
---|
ContextEnvironment(ClusterClient<?> remoteConnection,
List<URL> jarFiles,
List<URL> classpaths,
ClassLoader userCodeClassLoader,
SavepointRestoreSettings savepointSettings) |
ContextEnvironmentFactory(ClusterClient<?> client,
List<URL> jarFilesToAttach,
List<URL> classpathsToAttach,
ClassLoader userCodeClassLoader,
int defaultParallelism,
boolean isDetached,
SavepointRestoreSettings savepointSettings) |
DetachedEnvironment(ClusterClient<?> remoteConnection,
List<URL> jarFiles,
List<URL> classpaths,
ClassLoader userCodeClassLoader,
SavepointRestoreSettings savepointSettings) |
Modifier and Type | Method and Description |
---|---|
static SavepointRestoreSettings |
SavepointRestoreSettings.forPath(String savepointPath) |
static SavepointRestoreSettings |
SavepointRestoreSettings.forPath(String savepointPath,
boolean allowNonRestoredState) |
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.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.