1

根据我对文档的阅读,在使用可查询状态时,必须检索与键关联的整个状态值。我希望能够在将 TaskManager 上的值返回给客户端之前,即在 QueryableStateClientProxy 或 QueryableStateServer 中转换它。

例如,在 MapState 的情况下,能够检索地图中特定键的数据而不必将整个 MapState 返回给客户端(尤其是在 MapState 很大的情况下)可能很有用。

我是对的,目前没有办法做到这一点吗?如果是这样,有谁知道这是否可能在某个地方的路线图上?我看到查询状态被标记为 beta 并且将来可能会改变。

谢谢。

4

1 回答 1

1

在当前版本(Flink 1.7.0)中,获取的值在返回之前是不能修改的。AFAIK,此功能也不在路线图上。

于 2018-12-03T09:41:18.367 回答