官网上讲这些 keyed state(ValueState<T>,ReducingState<T> ,ListState<T> ,AggregatingState<IN, OUT> ,MapState<UK, UV> )
支持在keyed stream中使用,言下之意就是只能在KeyedProcessFunction中使用?但是实际使用中,我在ProcessAllWindowFunction和ProcessWindowFunction也能使用上述这些State,这是什么原因?
*来自志愿者整理的flink邮件归档
keyed state 只能在 keyeed stream 中使用。ProcessAllWindowFunction 和
ProcessWindowFunction 这两个都是 Window 上的 function,window 已经是 keyed stream 了
*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。