StateTtlConfig.Builder |
StateTtlConfig.Builder.cleanupFullSnapshot() |
Cleanup expired state in full snapshot on checkpoint.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.cleanupIncrementally(int cleanupSize,
boolean runCleanupForEveryRecord) |
Cleanup expired state incrementally cleanup local state.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.cleanupInRocksdbCompactFilter(long queryTimeAfterNumEntries) |
Cleanup expired state while Rocksdb compaction is running.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.cleanupInRocksdbCompactFilter(long queryTimeAfterNumEntries,
java.time.Duration periodicCompactionTime) |
Cleanup expired state while Rocksdb compaction is running.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.disableCleanupInBackground() |
Disable default cleanup of expired state in background (enabled by default).
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.neverReturnExpired() |
|
static StateTtlConfig.Builder |
StateTtlConfig.newBuilder(java.time.Duration ttl) |
|
static StateTtlConfig.Builder |
StateTtlConfig.newBuilder(Time ttl) |
Deprecated.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.returnExpiredIfNotCleanedUp() |
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setStateVisibility(StateTtlConfig.StateVisibility stateVisibility) |
Sets the state visibility.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setTimeToLive(java.time.Duration ttl) |
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setTtl(Time ttl) |
Deprecated.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setTtlTimeCharacteristic(StateTtlConfig.TtlTimeCharacteristic ttlTimeCharacteristic) |
Sets the time characteristic.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setUpdateType(StateTtlConfig.UpdateType updateType) |
Sets the ttl update type.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.updateTtlOnCreateAndWrite() |
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.updateTtlOnReadAndWrite() |
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.useProcessingTime() |
|