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

实时额度计算Flink实践课

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与实时额度计算概述
实时额度计算的应用场景（风控 · 金融 · 电商）
课程导学实时额度计算概述
02
Flink核心概念速览
DataStream · Event Time · Processing Time
Flink核心概念速览
03
开发环境搭建
JDK · Maven · Flink集群（Standalone…
开发环境搭建JDK
04
Flink DataStream API基础
Source（Kafka · Socket · 集合）
FlinkDataStream
05
Flink时间语义与Watermark
Event Time与Process… · Watermark生成策略 · Allowed Lateness
FlinkWatermark
06
Flink窗口机制
Tumbling Window · Sliding Window · Session Window
Flink窗口机制
07
Flink状态编程
Keyed State（ValueS… · ListState · MapState）
Flink状态编程
08
Flink Checkpoint与容错机制
Checkpoint原理 · Exactly-Once语义 · Savepoint
FlinkCheckpoint
09
Flink Table & SQL入门
TableEnvironment · 动态表 · 流表转换
FlinkTable
10
实时额度计算业务模型
额度模型（授信额度 · 可用额度 · 已用额度）
实时额度计算业务…额度模型
11
额度数据源接入
Kafka Topic设计 · JSON/AVRO序列化 · Schema Registry集成
额度数据源接入Kafka
12
额度初始化与快照加载
从MySQL/HBase加载初始额度 · Broadcast State分发配… · Keyed State初始化
额度初始化快照加载
13
实时额度扣减逻辑
消费事件流 · 扣减规则（单笔扣减 · 批量扣减）
实时额度扣减逻辑消费事件流
14
实时额度恢复逻辑
还款/退款事件处理 · 额度恢复策略（全额恢复 · 按比例恢复）
实时额度恢复逻辑还款
15
额度冻结与解冻
冻结事件处理 · 冻结状态管理 · 解冻触发条件
额度冻结解冻
16
额度过期与失效处理
T+1过期策略 · 定时器（Timer Service）… · 过期事件清理
额度过期失效处理
17
多维度额度聚合
按用户 · 按产品 · 按渠道聚合额度
多维度额度聚合按用户
18
额度变更历史记录
Side Output输出变更日志 · 写入HBase/ClickHouse · 支持回溯查询
额度变更历史记录Side
19
实时额度预警与监控
阈值告警（低额度预警 · 超额预警） · 使用ProcessFunction发…
实时额度预警监控
20
Flink CEP在额度风控中的应用
复杂事件模式（连续扣减 · 异常高频） · Pattern API
FlinkCEP
21
双流Join与额度对账
Connect与CoProcessF… · 事件时间Join · 延迟数据对账
Join双流
22
异步IO与外部存储交互
AsyncIO查询Redis/MyS… · 超时与重试策略 · 异步额度校验
IO异步
23
Flink SQL实现额度计算
使用SQL定义额度扣减/恢复逻辑 · Temporal Table Joi… · Retract Stream
FlinkSQL
24
状态后端优化与RocksDB调优
RocksDB配置（内存 · Block Cache · Write Buffer）
RocksDB状态后端优化
25
Flink作业性能调优
并行度设置 · 算子链 · Buffer Timeout
Flink作业性能调优
26
端到端Exactly-Once语义
Kafka Source/Sink… · 两阶段提交 · 事务性写入
Exactly-Once端到端
27
实时额度计算数据一致性保障
幂等设计 · 状态回滚 · 补偿机制
实时额度计算数据…幂等设计
28
Flink作业部署与运维
YARN/K8s部署 · 作业提交参数 · 日志采集
Flink作业部署
29
项目实战
实时风控额度系统（上）：需求分析 · 架构设计 · 数据流设计
项目实战实时风控额度系统
30
项目实战
实时风控额度系统（下）：代码实现 · 单元测试 · 集成测试
项目实战实时风控额度系统