Flink流计算编程--状态与检查点

一、Exactly_once简介 Exactly_once语义是Flink的特性之一,那么Flink到底提供了什么层次的Excactly_once?有人说是是每一个算子保证只处理一次,有人说是每条数据保证只处理一次。其实理解这个语义并不难,直接在官方文档中就能够看出: html 从图中能够看出:Exactly_once是为有状态的计算准备的!java 换句话说,没有状态的算子操做(operator
相关文章
相关标签/搜索