Flink作为大数据杀手级应用, 本次简单介绍一下Flink.

架构

Flink将状态存储在内存中, 定期持久化.

数据源

• 有界数据流: 输入数据有始有终, 例如一段时间产生的数据.
• 无界数据流: 输入数据有始无终.

窗口

• 根据时间划分窗口(Time Driven Window).
• 根据数据划分窗口(Data Driven Window).
• 滚动窗口: 窗口长度固定, 无重叠.
• 滑动窗口: 窗口长度固定, 有重叠.
• 会话窗口: 超时后创建新窗口, 窗口长度可变, 无重叠.