Package | Description |
---|---|
org.apache.flink.api.common.state |
Modifier and Type | Method and Description |
---|---|
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.disableCleanupInBackground()
Disable default cleanup of expired state in background (enabled by default).
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.neverReturnExpired() |
static StateTtlConfig.Builder |
StateTtlConfig.newBuilder(Time ttl) |
StateTtlConfig.Builder |
StateTtlConfig.Builder.returnExpiredIfNotCleanedUp() |
StateTtlConfig.Builder |
StateTtlConfig.Builder.setStateVisibility(StateTtlConfig.StateVisibility stateVisibility)
Sets the state visibility.
|
StateTtlConfig.Builder |
StateTtlConfig.Builder.setTtl(Time ttl)
Sets the ttl time.
|
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() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.