郑晓个人博客 | 随笔记录生活
佛布朗斯基
冰洛博客
实用软件应用下载-热门手游大全-全面手机游戏攻略教程
java (6368) elasticsearch (107) 丁d博客 (2) cicd自动化部署 (2)
本文将从状态的概念入手，详细介绍 Flink 中的状态分类、状态的使用、持久化及状态后端的配置。
处理函数（ProcessFunction）了。处理函数提供了一个“定时服务”（TimerService），我们可以通过它访问流中的事件（event）、时间戳（timestamp）、水位线（watermark），甚至可以注册“定时事件”。而且处理函数继承了 AbstractRichFunction 抽象类，所以拥有富函数类的所有特性，同样可以访问状态（state）和其他运行时信息。此外，处理函数还可以直接将数据输出到侧输出流（side output）中。所以，处理函数是最为灵活的处理方法，可以实现各种自定义的业务逻辑；同时也是整个 DataStream API 的底层基础。
本文介绍一下Flink一些基本概念并行度、slot及对应的组件