Flink有状态流处理_有状态的数据

作者：一键难忘520 | 2024-08-03 06:09:33

踩

有状态的数据

Flink有状态流处理

Flink中的算子是可以有状态的，因此可以积累事件之前所有事件数据的结果。
Flink应用程序可以在分布式集群上并行运行，其中每个算子的各个并行实例会在单独的线程中独立运行，并且在通常情况下，这些并行实例会在不同的机器上运行
有状态算子的并行实例组在存储其对应状态时，通常是按照键（Key）进行分片存储的。每个并行实例算子负责处理一组特定建的事件数据，并且这组键对应的状态会被保存在本地

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/一键难忘520/article/detail/921728