Flink项目实战课程介绍
Flink API通用基本概念
Flink DataStream API
Flink Time的故事
Flink Window那些事
Flink DataStream状态与容错
- Flink State介绍与作用
- 没有状态的日志如何度过
- Flink各种状态详解
- Flink Operator State使用案例
- Flink Operator State重分配
- Flink 使用Operator State的两种方式
- Flink Keyed State案例
- Flink Keyed State 重新分配
- Flink Keyed State TTL
- Flink Broadcast State
- Flink 状态与容错
- Flink checkpointing机制与使用前提条件
- Flink 启动checkpointing
- Flink 选择合适的State Backend
- Flink 配置重启策略
- Flink 数据栅栏Barrier
- Flink Savepoint
Flink Kafka Connector
Flink实时电商运营项目实战
- Flink项目需求
- Flink项目分析
- Flink系统架构设计
- Flink数据流程设计
- Data Processor介绍
- Data Processor安装使用
- 编辑UserEvent词典
- 编辑UserEvent模板
- 分析模板模拟数据
- 手写一个用户事件 Kafka生产者
- 手写一个渠道配置 Kafka生产者
- 用户行为数据实时打入Kafka
- Flink项目参数校验
- Flink项目checkpoint和重启策略配置
- Lombok注解使用说明
- 定义事件流对象及反序列化类
- IDEA自动生成serialVersionUID
- 开发Kafka事件流消费者
- 定义配置流对象及反序列化类
- 开发Kafka配置流消费者
- 定义计算结果对象及序列化类
- 链接事件流和配置流
- 处理广播流中的传入的配置
- 处理用户事件流中的数据
- 相关业务指标计算
- 项目联调及总结
0/1024
暂无留言
