VIP10
本课程属于：037-Kafka与Flink金融实时数据工程 智能金融与金融工程 · 共 10 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink事件时间、窗口与多流关联实战

共计 30 章节
可可资料掘金营 · 点击在线试看
01
课程导入
目标=Flink在流处理领域的定位 · 事件时间与窗口的核心价值 · 多流关联的典型场景
课程导入Flink
02
Flink基础回顾
目标=DataStream API · 执行环境 · 数据源与数据汇
Flink基础回顾
03
时间语义详解
目标=事件时间 · 处理时间与摄入时间的区别 · 时间戳分配
时间语义详解目标=事件时间
04
水位线深入
目标=Watermark策略 · 周期性水位线与标点水位线 · 空闲源处理
水位线深入Watermark
05
窗口基础
目标=窗口概念 · 键控窗口与非键控窗口 · 滚动窗口
窗口基础目标=窗口概念
06
窗口分配器与触发器
目标=WindowAssigner · Trigger · Evictor
窗口分配器触发器
07
事件时间窗口实战
目标=基于事件时间的滚动窗口统计 · 滑动窗口聚合 · 会话窗口分析
事件时间窗口实战目标=基于事件时…
08
窗口函数与状态
目标=ReduceFunction · AggregateFunction · ProcessWindowFunct…
窗口函数状态
09
多流关联概述
目标=双流Join · 多流Join · 维表关联
多流关联概述Join
10
基于窗口的Join
目标=Tumbling Window… · Sliding Window Joi… · Session Window Joi…
Join基于窗口的
11
Interval Join实战
目标=区间Join语义 · 事件时间区间条件 · 上下界设置
IntervalJoin
12
维表关联实战
目标=异步IO · 广播状态 · Lookup Join
维表关联实战IO
13
多流关联进阶
目标=CoProcessFuncti… · KeyedCoProcessFunc… · 广播连接
多流关联进阶CoProcessFun…
14
事件时间与多流关联综合案例
目标=电商订单与支付流关联 · 用户行为与广告点击关联 · 实时风控多流匹配
事件时间多流关联综合案例
15
状态管理与容错
目标=Keyed State · Operator State · 状态TTL
状态管理容错
16
性能调优
目标=并行度设置 · 水位线延迟与吞吐权衡 · 窗口粒度选择
性能调优目标=并行度设置
17
常见问题排查
目标=数据倾斜 · 水位线不推进 · 窗口不触发
常见问题排查目标=数据倾斜
18
生产环境实践
目标=监控指标 · 日志与告警 · 资源规划
生产环境实践目标=监控指标
19
Flink SQL与Table API
目标=事件时间DDL · 窗口TVF · Interval Join SQL
FlinkSQL
20
综合项目一
目标=实时订单宽表构建 · 完成订单流 · 支付流与维表的多流关联
综合项目一目标=实时订单宽…
21
综合项目二
目标=实时用户行为分析 · 完成点击流 · 曝光流与用户维表的关联
综合项目二目标=实时用户行…
22
综合项目三
目标=实时风控多流匹配 · 完成交易流 · 登录流与黑名单流的关联
综合项目三目标=实时风控多…
23
测试与调试
目标=单元测试 · MiniCluster测试 · 事件时间模拟
测试调试
24
部署与运维
目标=集群模式 · 作业提交 · 高可用配置
部署运维
25
进阶主题
目标=CEP复杂事件处理 · Flink ML · Gelly图计算
进阶主题CEP
26
课程总结
目标=事件时间 · 窗口与多流关联知识体系梳理 · 核心设计模式
课程总结目标=事件时间
27
实战答疑一
目标=事件时间与水位线常见疑问 · 窗口延迟与迟到数据取舍 · Join语义与状态清理策略
实战答疑一目标=事件时间
28
实战答疑二
目标=多流关联性能瓶颈 · 维表关联一致性 · 检查点与状态恢复问题
实战答疑二目标=多流关联性…
29
能力提升
目标=从需求到Flink作业的设计方… · 架构选型 · 代码规范
能力提升Flink
30
结业项目
目标=独立完成一个端到端实时多流关联… · 包含事件时间窗口 · 多流Join
结业项目目标=独立完成一…