开发者社区> 问答> 正文

Apache Flink:有没有办法在可查询状态返回到客户端之前进行转换?

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

例如,在MapState的情况下,能够检索映射中特定键的数据并且不必将整个MapState返回给客户端(特别是如果MapState很大)可能是有用的。

目前无法做到这一点吗?如果是这样,是否是在某个地方的路线图上?我看到查询状态被标记为beta,并且可能在将来发生变化。

展开
收起
flink小助手 2018-12-13 14:22:37 2105 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

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

    2019-07-17 23:20:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Flink技术进阶 立即下载
Apache Spark: Cloud and On-Prem 立即下载
Hybrid Cloud and Apache Spark 立即下载

相关镜像