集合的Flink状态TTL过期

Question

https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/state/state.html#state-time-to-live-ttl

我想确定TTL特性启用的位置，是在key字段上还是在value字段上。特别是，假设我有一个像这样的mapState结构：

mapState = Map[String,List[String]]
e.g. val mapState = Map("haha" -> List("foo","bar")) in Scala
where "haha" is the key of the mapState and List("foo","bar") is the value

如果我要通过StateTtlConfig在mapState上设置1分钟的TTL，那么立即（少于1分钟）写入List中的一个值，比如“foo”。

那么1分钟后，当TTL开火时，是键“哈哈”过期还是值“bar”过期？

换句话说，如果它在密钥上过期，我的理解是mapState将保持不变

mapstate=Map（“haha”->List（“foo”,“bar”）)

mapState = Map("haha" -> List("foo"))

因为值“bar”将在1分钟后过期而未被访问。

希望，我把问题说清楚了，提前谢谢你任何形式的帮助。

Answer 1

使用TTL访问状态的代码如下所示：

<SE extends Throwable, CE extends Throwable, CLE extends Throwable, V> TtlValue<V> getWrappedWithTtlCheckAndUpdate(
        SupplierWithException<TtlValue<V>, SE> getter,
        ThrowingConsumer<TtlValue<V>, CE> updater,
        ThrowingRunnable<CLE> stateClear) throws SE, CE, CLE {
        TtlValue<V> ttlValue = getter.get();
        if (ttlValue == null) {
            return null;
        } else if (expired(ttlValue)) {
            stateClear.run();
            if (!returnExpired) {
                return null;
            }
        } else if (updateTsOnRead) {
            updater.accept(rewrapWithNewTs(ttlValue));
        }
        return ttlValue;
    }

验证该值是否过期的方法如下所示：

    static <V> boolean expired(@Nullable TtlValue<V> ttlValue, long ttl, long currentTimestamp) {
        return ttlValue != null && expired(ttlValue.getLastAccessTimestamp(), ttl, currentTimestamp);
    }

这基本上意味着在本例中，它将检查整个列表的TTL，而不是单独的元素。因此，根据statettlconfig的不同，整个列表将过期，或者整个列表不会过期。