当前位置:   article > 正文

flink的状态管理(state manage)与可查询状态_flink state 查看工具

flink state 查看工具

1.什么是状态管理

2.可查询状态

有什么应用场景????

什么是状态管理:https://blog.csdn.net/xorxos/article/details/80877266

 

 

可查询状态

引入可查询状态的好处将有助于消除对键值存储(key-value stores)之类的外部系统的依赖,这些键值存储在实践中经常是瓶颈,正如上图所示。将Flink内部的状态暴露给外部实际上是将数据库的很大一部分工作移动到流处理器中,这将提供高吞吐量查询,而且计算好的状态可以立即被访问。
 

整个过程如下:(1)、查询客户端请求了一个可查询状态:/job/operation/state-name/key,Flink会请求State Location Server得到 key-partition 的存储位置;
(2)、而State Location Server会从ExecutionGraph中查找位置;
(3)、当 key-partition 的存储位置找到之后,会提供给查询客户端;
(4)、查询客户端根据状态存储的位置向相应的State Registry查询 state-name 和 key;
(5)、最后State Registry将结果返回给查询客户端,这样客户端就得到了相应的状态信息。

可查询状态实现案例:https://blog.csdn.net/wangpei1949/article/details/100608828

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/寸_铁/article/detail/916428
推荐阅读
相关标签
  

闽ICP备14008679号