Class StateTtlConfig.CleanupStrategies
- java.lang.Object
-
- org.apache.flink.api.common.state.StateTtlConfig.CleanupStrategies
-
- All Implemented Interfaces:
Serializable
- Enclosing class:
- StateTtlConfig
public static class StateTtlConfig.CleanupStrategies extends Object implements Serializable
TTL cleanup strategies.This class configures when to cleanup expired state with TTL. By default, state is always cleaned up on explicit read access if found expired. Currently cleanup of state full snapshot can be additionally activated.
- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StateTtlConfig.IncrementalCleanupStrategygetIncrementalCleanupStrategy()StateTtlConfig.RocksdbCompactFilterCleanupStrategygetRocksdbCompactFilterCleanupStrategy()booleaninFullSnapshot()booleaninRocksdbCompactFilter()booleanisCleanupInBackground()
-
-
-
Method Detail
-
inFullSnapshot
public boolean inFullSnapshot()
-
isCleanupInBackground
public boolean isCleanupInBackground()
-
getIncrementalCleanupStrategy
@Nullable public StateTtlConfig.IncrementalCleanupStrategy getIncrementalCleanupStrategy()
-
inRocksdbCompactFilter
public boolean inRocksdbCompactFilter()
-
getRocksdbCompactFilterCleanupStrategy
@Nullable public StateTtlConfig.RocksdbCompactFilterCleanupStrategy getRocksdbCompactFilterCleanupStrategy()
-
-