Fabian Hueske

Fabian Hueske

State Processor API:如何读取,写入和修改 Flink 应用程序的状态
State Processor API:如何读取,写入和修改 Flink 应用程序的状态

过去无论是在生产中使用,还是调研 Apache Flink,总会遇到一个问题:如何访问和更新 Flink 保存点(savepoint)中保存的 state?Apache Flink 1.9 引入了****状态处理器(State Processor)API,它是基于 DataSet API 的强大扩展,允许读取,写入和修改 Flink 的保存点和检查点(checkpoint)中的状态

Apache Flink 中广播状态的实用指南
Apache Flink 中广播状态的实用指南

Via:https://flink.apache.org/2019/06/26/broadcast-state.html自版本 Flink 1.5.0 以来,Apache Flink 提供了一种新的状态类型,称为广播状态(Broadcast State)。在本文中,将解释什么是广播状态,并通过示例演示如何将广播状态应用在评估基于事件流的动态模式的应用程序,并指导大家学习广播状态的处理步骤和相关源码,以便在今后的实践中能实现此类的应用。

Apache Flink 1.8.0 中的状态生存时间特性:如何自动清理应用程序的状态
Apache Flink 1.8.0 中的状态生存时间特性:如何自动清理应用程序的状态

原文链接: https://flink.apache.org/2019/05/19/state-ttl.html对于许多状态流式计算程序来说,一个常见的需求是自动清理应用程序的状态(state),以便有效地控制状态大小,或者控制程序访问状态的有效时间(例如受限于诸如GDPR等法律条规)。Apache Flink 自 1.6.0 版本引入了状态的生存时间(time-to-live,TTL)功能,使得应用程序的状态清理和有效的状态大小管理成为可能。

  • 关注
    • qr_code

      微信公众号

      最新前沿最热资讯

    • qr_code

      技术支持钉钉群

      时时刻刻得到帮助

  • TOP