[hotfix] Fix the StateTtlConfig#newBuilder doc from Time to Duration
diff --git a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
index 80f444b..2635c11 100644
--- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
@@ -305,7 +305,7 @@
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();
@@ -321,7 +321,7 @@
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
@@ -399,7 +399,7 @@
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground()
.build();
```
@@ -409,7 +409,7 @@
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground
.build
```
@@ -441,7 +441,7 @@
import org.apache.flink.api.common.time.Time;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot()
.build();
```
@@ -452,7 +452,7 @@
import org.apache.flink.api.common.time.Time
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot
.build
```
@@ -487,7 +487,7 @@
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build();
```
@@ -496,7 +496,7 @@
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build
```
@@ -537,7 +537,7 @@
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();
```
@@ -547,7 +547,7 @@
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
```
diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md b/docs/content/docs/dev/datastream/fault-tolerance/state.md
index 0d5705e..233f9bd 100644
--- a/docs/content/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md
@@ -344,7 +344,7 @@
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();
@@ -360,7 +360,7 @@
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
@@ -447,7 +447,7 @@
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground()
.build();
```
@@ -456,7 +456,7 @@
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.disableCleanupInBackground
.build
```
@@ -491,7 +491,7 @@
import org.apache.flink.api.common.time.Time;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot()
.build();
```
@@ -502,7 +502,7 @@
import org.apache.flink.api.common.time.Time
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupFullSnapshot
.build
```
@@ -543,7 +543,7 @@
```java
import org.apache.flink.api.common.state.StateTtlConfig;
StateTtlConfig ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build();
```
@@ -552,7 +552,7 @@
```scala
import org.apache.flink.api.common.state.StateTtlConfig
val ttlConfig = StateTtlConfig
- .newBuilder(Time.seconds(1))
+ .newBuilder(Duration.ofSeconds(1))
.cleanupIncrementally(10, true)
.build
```
@@ -600,7 +600,7 @@
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();
```
@@ -610,7 +610,7 @@
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
```
