Flink

简介

Flink提供面向流式处理的接口(DataStream API)和面向批处理的接口(DataSet API)

• 分布式
• 高吞吐
• 压力下保持正确
• 操作简单
• 低延迟
• 时间正确/语义化窗口

原理

JobManager调度TaskManager执行task

• 无界数据流：有开始、没结束
• 有界数据流：有开始、有结束