Flink:有状态算子和无状态算子
本文重点
在Flink中，算子任务可以分为无状态和有状态两种情况。在Flink中，可以通过使用算子状态和无算子状态来灵活地处理不同类型的计算任务。根据具体的需求和场景，选择合适的状态管理方式可以提高计算任务的效率和性能。
算子状态和无算子状态
算子状态
算子状态是指在算子函数中维护的状态，用于保存和更新算子函数的中间结果。算子状态可以在算子函数的生命周期内保持可见性，并且可以通过checkpointing机制进行持久化和恢复。算子状态适用于需要保存中间结果的计算任务，例如聚合操作、窗口操作等。
无算子状态
无算子状态是指不需要在算子函数中维护的状态。无算子状态是一种临时性的状态，只在算子函数的单次调用中有效，不会被保存和恢复。无算子状态适用于一些无状态的计算任务，例如map、filter、flatMap， 计算时不依赖其他数据，就都属于