VIP20
本课程属于：017-Flink实时计算 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

复杂事件窗口计算模型设计

📚 共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
事件驱动架构概述
事件驱动定义、与微服务的关系、核心组件：生产者、消费者、事件总线。
架构EDA
02
窗口计算基础
窗口计算定义、在流处理中的角色、滚动/滑动/会话窗口概览。
流处理基础
03
时间语义与水位线
事件时间、处理时间、摄入时间、水位线机制与生成策略。
时间Watermark
04
滚动窗口 (Tumbling)
定义与特性、触发条件、Flink/Spark实现、应用场景。
滚动窗口无重叠
05
滑动窗口 (Sliding)
定义与特性、触发条件、Flink/Spark实现、应用场景。
滑动窗口重叠
06
会话窗口 (Session)
定义与特性、触发条件、Flink/Spark实现、应用场景。
会话窗口超时
07
全局窗口 (Global)
定义与特性、触发条件、Flink/Spark实现、应用场景。
全局窗口自定义
08
窗口分配器
分配器作用、内置分配器、自定义分配器、性能考量。
Assigner路由
09
窗口函数
ReduceFunction、AggregateFunction、ProcessWindowFunction 对比。
函数聚合
10
触发器 (Trigger)
触发器作用、内置/自定义触发器、触发时机与策略。
Trigger策略
11
驱逐器 (Evictor)
驱逐器作用、内置/自定义驱逐器、与触发器协同。
Evictor清理
12
允许延迟 (Allowed Lateness)
延迟定义、配置、延迟数据处理、侧输出使用。
延迟SideOutput
13
状态管理与窗口状态
状态定义、ValueState/ListState/MapState、状态后端选择。
状态StateBackend
14
窗口性能优化
瓶颈分析、并行度优化、数据倾斜、内存调优。
性能调优
15
CEP 基础
CEP定义、与窗口关系、核心概念：模式、序列、匹配。
CEP模式
16
CEP 模式定义
Pattern定义、序列、模式组、匹配策略。
Pattern序列
17
CEP 时间约束
时间窗口在CEP中的应用、时间约束配置与实现。
时间约束
18
CEP 条件约束
简单条件、组合条件、条件约束代码实现。
条件过滤
19
CEP 跳过策略
NO_SKIP、SKIP_TO_NEXT、SKIP_PAST_LAST_EVENT、SKIP_TO_FIRST/LAST。
跳过策略
20
CEP 超时处理
超时定义、处理机制、代码实现。
超时Timeout
21
CEP实战：用户行为异常检测
需求分析、数据模型、CEP模式、代码与测试。
异常检测实战
22
CEP实战：交易风控系统
需求分析、数据模型、CEP模式、代码与测试。
风控交易
23
CEP实战：物联网设备监控
需求分析、数据模型、CEP模式、代码与测试。
IoT监控
24
窗口计算与CEP集成
协同工作、集成方案设计、代码实现。
集成协同
25
分布式窗口计算
挑战、Exactly-Once、Checkpoint/Savepoint容错。
分布式容错
26
Flink窗口实现
Flink窗口架构、API、配置详解。
Flink实现
27
Spark Structured Streaming窗口
Spark窗口架构、API、配置。
SparkStructured
28
Kafka Streams窗口
Kafka Streams窗口架构、API、配置。
KafkaStreams
29
Beam窗口实现
Beam窗口模型、API、配置。
Beam统一
30
窗口计算最佳实践
窗口类型选择、大小配置、性能调优、监控告警。
最佳实践策略