Package | Description |
---|---|
org.apache.flink.state.api |
Modifier and Type | Method and Description |
---|---|
SavepointWriter |
SavepointWriter.changeOperatorIdentifier(OperatorIdentifier from,
OperatorIdentifier to)
Changes the identifier of an operator.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(StreamExecutionEnvironment executionEnvironment,
String path)
Loads an existing savepoint.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(StreamExecutionEnvironment executionEnvironment,
String path,
StateBackend stateBackend)
Loads an existing savepoint.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(String path)
Deprecated.
|
static SavepointWriter |
SavepointWriter.fromExistingSavepoint(String path,
StateBackend stateBackend)
|
static SavepointWriter |
SavepointWriter.newSavepoint(int maxParallelism)
Deprecated.
|
static SavepointWriter |
SavepointWriter.newSavepoint(StateBackend stateBackend,
int maxParallelism)
Deprecated.
|
static SavepointWriter |
SavepointWriter.newSavepoint(StreamExecutionEnvironment executionEnvironment,
int maxParallelism)
Creates a new savepoint.
|
static SavepointWriter |
SavepointWriter.newSavepoint(StreamExecutionEnvironment executionEnvironment,
StateBackend stateBackend,
int maxParallelism)
Creates a new savepoint.
|
SavepointWriter |
SavepointWriter.removeOperator(OperatorIdentifier identifier)
Drop an existing operator from the savepoint.
|
SavepointWriter |
SavepointWriter.removeOperator(String uid)
Deprecated.
|
<T> SavepointWriter |
SavepointWriter.withConfiguration(ConfigOption<T> option,
T value)
Sets a configuration that will be applied to the stream operators used to bootstrap a new
savepoint.
|
<T> SavepointWriter |
SavepointWriter.withOperator(OperatorIdentifier identifier,
StateBootstrapTransformation<T> transformation)
Adds a new operator to the savepoint.
|
<T> SavepointWriter |
SavepointWriter.withOperator(String uid,
StateBootstrapTransformation<T> transformation)
Deprecated.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.