Re: State里面用guava Cache

Wed, 08 Jul 2020 00:56:53 -0700 

TTL state[1] 满足你的需求吗? 如果不满足的话，能否描述下你的需求呢？

[1]
https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/stream/state/state.html#%E7%8A%B6%E6%80%81%E6%9C%89%E6%95%88%E6%9C%9F-ttl
Best,
Congxian


op <[email protected]> 于2020年7月8日周三 下午3:53写道：

> 您好，我主要是觉得Cache的自动过期比较好用
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:&nbsp;"Congxian Qiu"<[email protected]&gt;;
> 发送时间:&nbsp;2020年7月8日(星期三) 下午3:50
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;Re: State里面用guava Cache
>
>
>
> 你好，为什么需要在 State 里面再用 cache 呢？单纯的 State 不能满足需求吗？需求是什么呢？
> 另外，除了 ValueState，其他的 ListState/MapState 能否满足你的需求呢？
>
> Best,
> Congxian
>
>
> op <[email protected]&gt; 于2020年7月8日周三 上午10:31写道：
>
> &gt; 大家好，我想使用一个 ValueState[Cache]的状态，但是发现这个状态的value 没办法更新，
> &gt;
> &gt;
> &gt; 比如我在map里面每次往cache里面put一个字符串，然后update这个state，输出cache的长度，为什么每次输出长度都是1

回复