Class StateTtlConfig.RocksdbCompactFilterCleanupStrategy
- java.lang.Object
-
- org.apache.flink.api.common.state.StateTtlConfig.RocksdbCompactFilterCleanupStrategy
-
- All Implemented Interfaces:
Serializable
- Enclosing class:
- StateTtlConfig
@PublicEvolving public static class StateTtlConfig.RocksdbCompactFilterCleanupStrategy extends Object
Configuration of cleanup strategy using custom compaction filter in RocksDB.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Duration
getPeriodicCompactionTime()
long
getQueryTimeAfterNumEntries()
-
-
-
Method Detail
-
getQueryTimeAfterNumEntries
public long getQueryTimeAfterNumEntries()
-
getPeriodicCompactionTime
public Duration getPeriodicCompactionTime()
-
-