Package | Description |
---|---|
org.apache.flink.streaming.api.environment |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> |
ExecutionCheckpointingOptions.EXTERNALIZED_CHECKPOINT |
Modifier and Type | Method and Description |
---|---|
CheckpointConfig.ExternalizedCheckpointCleanup |
CheckpointConfig.getExternalizedCheckpointCleanup()
Returns the cleanup behaviour for externalized checkpoints.
|
static CheckpointConfig.ExternalizedCheckpointCleanup |
CheckpointConfig.ExternalizedCheckpointCleanup.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CheckpointConfig.ExternalizedCheckpointCleanup[] |
CheckpointConfig.ExternalizedCheckpointCleanup.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
CheckpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup cleanupMode)
Deprecated.
|
void |
CheckpointConfig.setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup cleanupMode)
Sets the mode for externalized checkpoint clean-up.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.