在使用可查询状态时,必须检索与键关联的整个状态值。我希望能够在返回到客户端之前将TaskManager上的值转换,即在QueryableStateClientProxy或QueryableStateServer中。
例如,在MapState的情况下,能够检索映射中特定键的数据并且不必将整个MapState返回给客户端(特别是如果MapState很大)可能是有用的。
目前无法做到这一点吗?如果是这样,是否是在某个地方的路线图上?我看到查询状态被标记为beta,并且可能在将来发生变化。
在当前版本(Flink 1.7.0)中,在返回之前无法修改获取的值。AFAIK,此功能也不在路线图上。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。