Yige

流处理 API 衍变（对比 Storm） Storm 的 API 抽象层次更低点，相当于是面向操作的，通过代码直接自己自定义构造 DAG Copy TopologyBuilder builder = new TopologyBuilder(); builder…

内容参考自: Apache Flink 零基础入门（一）：基础概念解析 有状态流式处理 概念 传统批次处理：持续收集数据，以时间作为批次划分的依据，周期性执行批次运算，这样可能存在的场景问题: 假如一个小时作为一个批次划分的依据，需要统计特定事件转换次数…