flink-state问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink-state问题

ゞ野蠻遊戲χ
Deal all


官网上讲这些 keyed state(ValueState<T&gt;,ReducingState<T&gt; ,ListState<T&gt; ,AggregatingState<IN, OUT&gt; ,MapState<UK, UV&gt; )
支持在keyed stream中使用,言下之意就是只能在KeyedProcessFunction中使用?但是实际使用中,我在ProcessAllWindowFunction和ProcessWindowFunction也能使用上述这些State,这是什么原因?




谢谢
jiazhi
Reply | Threaded
Open this post in threaded view
|

Re: flink-state问题

Congxian Qiu
Hi

keyed state 只能在 keyeed stream 中使用。ProcessAllWindowFunction 和
ProcessWindowFunction 这两个都是 Window 上的 function,window 已经是 keyed stream 了

Best,
Congxian


ゞ野蠻遊戲χ <[hidden email]> 于2020年7月8日周三 下午11:29写道:

> Deal all
>
>
> 官网上讲这些 keyed state(ValueState<T&gt;,ReducingState<T&gt; ,ListState<T&gt;
> ,AggregatingState<IN, OUT&gt; ,MapState<UK, UV&gt; )
> 支持在keyed
> stream中使用,言下之意就是只能在KeyedProcessFunction中使用?但是实际使用中,我在ProcessAllWindowFunction和ProcessWindowFunction也能使用上述这些State,这是什么原因?
>
>
>
>
> 谢谢
> jiazhi