Flink
简介
Flink提供面向流式处理的接口(DataStream API)和面向批处理的接口(DataSet API)
- 分布式
- 高吞吐
- 压力下保持正确
- 操作简单
- 低延迟
- 时间正确/语义化窗口
原理
JobManager调度TaskManager执行task
- 无界数据流:有开始、没结束
- 有界数据流:有开始、有结束
Flink提供面向流式处理的接口(DataStream API)和面向批处理的接口(DataSet API)
JobManager调度TaskManager执行task