Skip to content

Commit

Permalink
[hotfix] Fix the StateTtlConfig#newBuilder doc from Time to Duration
Browse files Browse the repository at this point in the history
  • Loading branch information
@1996fanrui @Myasuka
1996fanrui authored and Myasuka committed Mar 2, 2024
1 parent 161defe commit 697d2b6
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 20 deletions.
20 changes: 10 additions & 10 deletions docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.api.common.time.Time;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
.build();
Expand All @@ -321,7 +321,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor
import org.apache.flink.api.common.time.Time

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
.build
Expand Down Expand Up @@ -399,7 +399,7 @@ Heap state backend 会额外存储一个包括用户状态以及时间戳的 Jav
import org.apache.flink.api.common.state.StateTtlConfig;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground()
.build();
```
Expand All @@ -409,7 +409,7 @@ StateTtlConfig ttlConfig = StateTtlConfig
import org.apache.flink.api.common.state.StateTtlConfig

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground
.build
```
Expand Down Expand Up @@ -441,7 +441,7 @@ import org.apache.flink.api.common.state.StateTtlConfig;
import org.apache.flink.api.common.time.Time;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot()
.build();
```
Expand All @@ -452,7 +452,7 @@ import org.apache.flink.api.common.state.StateTtlConfig
import org.apache.flink.api.common.time.Time

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot
.build
```
Expand Down Expand Up @@ -487,7 +487,7 @@ ttl_config = StateTtlConfig \
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build();
```
Expand All @@ -496,7 +496,7 @@ import org.apache.flink.api.common.state.StateTtlConfig;
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build
```
Expand Down Expand Up @@ -537,7 +537,7 @@ Flink 提供的 RocksDB 压缩过滤器会在压缩时过滤掉已经过期的
import org.apache.flink.api.common.state.StateTtlConfig;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1))
.build();
```
Expand All @@ -547,7 +547,7 @@ StateTtlConfig ttlConfig = StateTtlConfig
import org.apache.flink.api.common.state.StateTtlConfig

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1))
.build
```
Expand Down
20 changes: 10 additions & 10 deletions docs/content/docs/dev/datastream/fault-tolerance/state.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -344,7 +344,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.api.common.time.Time;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
.build();
Expand All @@ -360,7 +360,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor
import org.apache.flink.api.common.time.Time

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
.build
Expand Down Expand Up @@ -447,7 +447,7 @@ in the background if supported by the configured state backend. Background clean
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground()
.build();
```
Expand All @@ -456,7 +456,7 @@ StateTtlConfig ttlConfig = StateTtlConfig
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground
.build
```
Expand Down Expand Up @@ -491,7 +491,7 @@ import org.apache.flink.api.common.state.StateTtlConfig;
import org.apache.flink.api.common.time.Time;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot()
.build();
```
Expand All @@ -502,7 +502,7 @@ import org.apache.flink.api.common.state.StateTtlConfig
import org.apache.flink.api.common.time.Time

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot
.build
```
Expand Down Expand Up @@ -543,7 +543,7 @@ This feature can be configured in `StateTtlConfig`:
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build();
```
Expand All @@ -552,7 +552,7 @@ import org.apache.flink.api.common.state.StateTtlConfig;
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build
```
Expand Down Expand Up @@ -600,7 +600,7 @@ This feature can be configured in `StateTtlConfig`:
import org.apache.flink.api.common.state.StateTtlConfig;

StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1))
.build();
```
Expand All @@ -610,7 +610,7 @@ StateTtlConfig ttlConfig = StateTtlConfig
import org.apache.flink.api.common.state.StateTtlConfig

val ttlConfig = StateTtlConfig
.newBuilder(Time.seconds(1))
.newBuilder(Duration.ofSeconds(1))
.cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1))
.build
```
Expand Down

0 comments on commit 697d2b6

Please sign in to comment.