VIP20
本课程属于：063-信用额度定价人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink实时额度计算学习资料

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Flink概述
Flink发展历史 · Flink核心特性 · Flink应用场景（实时额度计算典型…
Flink发展历史
02
Flink架构与组件
Flink运行时架构 · JobManager · TaskManager
Flink架构
03
Flink环境搭建
本地模式 · Standalone集群模式 · YARN模式部署与配置
Flink环境搭建
04
Flink DataStream API基础
DataStream编程模型 · Source · Transformation
FlinkDataStream
05
Flink时间语义
EventTime · IngestionTime · ProcessingTime
Flink时间语义
06
Flink窗口机制
滚动窗口 · 滑动窗口 · 会话窗口
Flink窗口机制
07
Flink状态管理
KeyedState与Operato… · 状态后端（Memory/Filesy…
Flink状态管理
08
Flink Checkpoint与Savepoint
容错机制 · Exactly-Once语义 · Checkpoint配置与调优
FlinkCheckpoint
09
Flink Table & SQL基础
Table API与SQL编程 · 动态表 · 流表转换
FlinkTable
10
Flink CEP复杂事件处理
Pattern API · 事件序列匹配 · 超时与跳过策略
FlinkCEP
11
实时额度计算业务模型
额度定义 · 额度类型（日额度/月额度/累计额度） · 额度生命周期
实时额度计算业务…额度定义
12
额度数据源接入
Kafka Source配置 · JSON/AVRO反序列化 · Schema Registry集成
额度数据源接入Kafka
13
额度计算核心逻辑
余额扣减 · 额度冻结 · 额度释放
额度计算核心逻辑余额扣减
14
额度计算中的状态设计
KeyedState存储用户额度 · 状态TTL · 状态分区策略
额度计算状态设计
15
额度计算中的时间窗口
按天/按月滚动窗口统计消费 · 窗口内额度校验
额度计算时间窗口
16
额度计算中的Watermark策略
乱序处理 · 延迟数据容忍度 · Watermark对齐
Watermark额度计算
17
额度计算中的Exactly-Once保证
端到端Exactly-Once · Kafka事务写入 · 幂等性设计
Exactly-Once额度计算
18
额度计算中的多流Join
用户信息流与交易流Join · 维表关联（HBase/Redis）
Join额度计算
19
额度计算中的告警与阈值
额度不足告警 · 超额拦截 · 实时通知（Webhook/短信）
额度计算告警
20
额度计算中的性能优化
并行度调整 · 算子链 · 数据倾斜处理
额度计算性能优化
21
Flink与Redis集成
Redis Sink/Source · 额度缓存 · 分布式锁
FlinkRedis
22
Flink与HBase集成
HBase维表查询 · 额度历史记录存储 · 批量写入优化
FlinkHBase
23
Flink与MySQL集成
JDBC Sink · 双写一致性 · 事务回滚
FlinkMySQL
24
Flink与Kafka集成
Kafka Exactly-Once… · 事务性写入 · 幂等生产者
FlinkKafka
25
Flink SQL实现额度计算
CREATE TABLE定义 · INSERT INTO实时计算 · 窗口聚合
FlinkSQL
26
Flink CEP实现额度异常检测
高频交易检测 · 额度盗刷识别 · 规则动态更新
FlinkCEP
27
Flink额度计算项目实战（一）
需求分析 · 数据模型设计 · 架构选型
Flink额度计算项目实战
28
Flink额度计算项目实战（二）
代码实现 · 单元测试 · 本地调试
Flink额度计算项目实战
29
Flink额度计算项目实战（三）
集群部署 · 性能压测 · 监控告警配置
Flink额度计算项目实战
30
Flink额度计算项目实战（四）
上线运维 · 问题排查 · 持续优化与总结
Flink额度计算项目实战