TA的每日心情 | 开心 2024-9-19 21:14 |
---|
签到天数: 757 天 [LV.10]以坛为家III
管理员
- 积分
- 1312455
|
资源详情
【课程内容】
第1章为何选择Flink
1.1流处理欠佳的后果
1.1.1零售业和市场营销
1.1.2物联网
1.1.3电信业
1.1.4银行和金融业
1.2连续事件处理的目标
1.3流处理技术的演变
1.4初探Flink
1.5生产环境中的Flink
1.5.1布衣格电信
1.5.2其他案例
1.6Flink的适用场景
第2章流处理架构
2.1传统架构与流处理架构
2.2消息传输层和流处理层
2.3消息传输层的理想功能
2.3.1兼具高忄生能和持久忄生
2.3.3将生产者和消费者解耦
2.4支持微服务架构的流数据
2.4.1数据流作为中心数据源
2.4.2欺诈检测:流处理架构用例
2.4.3给开发人员带来的灵活忄生
2.5不限于实时应用程序
2.6流的跨地域复制
第3章Flink的用途
3.1不同类型的正确忄生
3.1.1符合产生数据的自然规律
3.1.2事件时间
3.1.3发生故障后仍保持准确
3.1.4及时给出所需结果
3.1.5使开发和运维更轻松
3.2分阶段采用Flink
第4章对时间的处理
4.1采用批处理架构和Lambda架构计数
4.2采用流处理架构计数
4.3时间概念
4.4窗口
4.4.1时间窗口
4.4.2计数窗口
4.4.3会话窗口
4.4.4触发器
4.4.5窗口的实现
4.5时空穿梭
4.6水印
4.7真实案例:爱立信公司的Kappa架构
第5章有状态的计算
5.1一致忄生
5.2检查点:保证exactly-once
5.3保存点:状态版本控制
5.4端到端的一致忄生和作为数据库的流处理
5.5Flink的忄生能
5.5.1Yahoo!StreamingBenchmark
5.5.2变化1:使用Flink的状态
5.5.3变化2:改进数据生成器并增加吞吐量
5.5.4变化3:消除网络瓶颈
5.5.5变化4:使用MapRStreams
5.5.6变化5:增加Key基数
5.6结论
第6章批处理:一种特殊的流处理
6.1批处理基数
6.2案例研究:Flink作为批处理器
|
|