org.apache.flink.api.common.state

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

Modifier and Type	Method and Description
StateTtlConfig.IncrementalCleanupStrategy	getIncrementalCleanupStrategy()
StateTtlConfig.RocksdbCompactFilterCleanupStrategy	getRocksdbCompactFilterCleanupStrategy()
boolean	inFullSnapshot()
boolean	inRocksdbCompactFilter()
boolean	isCleanupInBackground()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()