public static class StateTtlConfig.Builder extends Object
StateTtlConfig
.Modifier and Type | Method and Description |
---|---|
StateTtlConfig |
build() |
StateTtlConfig.Builder |
cleanupFullSnapshot()
Cleanup expired state in full snapshot on checkpoint.
|
StateTtlConfig.Builder |
neverReturnExpired() |
StateTtlConfig.Builder |
returnExpiredIfNotCleanedUp() |
StateTtlConfig.Builder |
setStateVisibility(StateTtlConfig.StateVisibility stateVisibility)
Sets the state visibility.
|
StateTtlConfig.Builder |
setTimeCharacteristic(StateTtlConfig.TimeCharacteristic timeCharacteristic)
Sets the time characteristic.
|
StateTtlConfig.Builder |
setTtl(Time ttl)
Sets the ttl time.
|
StateTtlConfig.Builder |
setUpdateType(StateTtlConfig.UpdateType updateType)
Sets the ttl update type.
|
StateTtlConfig.Builder |
updateTtlOnCreateAndWrite() |
StateTtlConfig.Builder |
updateTtlOnReadAndWrite() |
StateTtlConfig.Builder |
useProcessingTime() |
@Nonnull public StateTtlConfig.Builder setUpdateType(StateTtlConfig.UpdateType updateType)
updateType
- The ttl update type configures when to update last access timestamp which prolongs state TTL.@Nonnull public StateTtlConfig.Builder updateTtlOnCreateAndWrite()
@Nonnull public StateTtlConfig.Builder updateTtlOnReadAndWrite()
@Nonnull public StateTtlConfig.Builder setStateVisibility(@Nonnull StateTtlConfig.StateVisibility stateVisibility)
stateVisibility
- The state visibility configures whether expired user value can be returned or not.@Nonnull public StateTtlConfig.Builder returnExpiredIfNotCleanedUp()
@Nonnull public StateTtlConfig.Builder neverReturnExpired()
@Nonnull public StateTtlConfig.Builder setTimeCharacteristic(@Nonnull StateTtlConfig.TimeCharacteristic timeCharacteristic)
timeCharacteristic
- The time characteristic configures time scale to use for ttl.@Nonnull public StateTtlConfig.Builder useProcessingTime()
@Nonnull public StateTtlConfig.Builder cleanupFullSnapshot()
@Nonnull public StateTtlConfig.Builder setTtl(@Nonnull Time ttl)
ttl
- The ttl time.@Nonnull public StateTtlConfig build()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.