一、有界流和无界流
- ①有界流:定义了流的开始,也定义了流的结束。
- ②无界流:定义了流的开始,但没定义流的结束。
二、有状态计算
- ①有状态计算:基于多个事件输出结果。
- ②无状态计算:观察每个独立事件,并根据最后一个事件输出结果。
三、Flink特点
- ①高吞吐、低延迟、高性能:阿里巴巴每秒30万订单。
- ②支持事件时间概念。
- ③支持有状态的计算。
- ④支持高度灵活的窗口操作。
- ⑤基于轻量级分布式快照实现容错。
- ⑥基于JVM独立的内存管理。
- ⑦保存点
其他框架:SparkStreaming、Trident、Storm。
- Flink简介
- flink搭建standalone模式与测试
- flink提交任务(界面方式)
- Flink项目初始化
- Java版WordCount(匿名类)
- Java版WordCount(lambda)
- Scala版WordCount
- Java版WordCount[批处理]
- Scala版WordCount[批处理]
- 流处理非并行的Source
- 流处理可并行的Source
- kafka的Source
- Flink算子(Map,FlatMap,Filter)
- Flink算子KeyBy
- Flink算子Reduce和Max与Min
- addSink自定义Sink
- startNewChain和disableChaining
- 资源槽slotSharingGroup
- 计数窗口
- 滚动窗口
- 滑动窗口
- Session窗口
- 按照EventTime作为标准