VIP20
本课程属于：015-保险精算模型坏样本归因 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

精算模型坏样本归因Flink实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
精算模型与坏样本归因概述
精算模型在保险风控中的作用 · 坏样本定义与归因目标 · Flink在实时归因中的价值
精算模型坏样本归因概述
02
Flink核心概念回顾
DataStream与DataSet… · 时间语义（Event Time/Pr… · Watermark机制
Flink核心概念回顾
03
精算数据流接入
Kafka数据源配置 · JSON/AVRO格式解析 · Schema Registry集成
精算数据流接入Kafka
04
坏样本特征工程
特征提取算子设计 · 滑动窗口聚合 · 特征归一化与分箱
坏样本特征工程特征提取算子设计
05
归因模型加载与推理
模型序列化格式（PMML/ONNX） · Flink Model Servin… · 批量推理与单条推理性能对比
归因模型加载推理
06
归因规则引擎
基于CEP的规则匹配 · 规则优先级与冲突处理 · 规则动态更新（广播流）
归因规则引擎CEP
07
归因结果输出
Sink到Elasticsearch · MySQL · Kafka
归因结果输出Sink
08
状态管理与容错
Keyed State与Operat… · Checkpoint与Savepoi… · Exactly-Once语义保障
状态管理容错
09
Flink SQL在归因中的应用
CREATE TABLE定义 · 窗口聚合查询 · UDF编写归因逻辑
FlinkSQL
10
实时归因Pipeline架构
Lambda架构 vs Kappa架… · 数据流DAG设计 · 背压监控与调优
Pipeline实时归因
11
坏样本归因指标计算
归因覆盖率 · 准确率 · 召回率
坏样本归因指标计…归因覆盖率
12
多模型集成归因
集成学习模型（XGBoost/Lig… · 模型投票与加权融合
多模型集成归因XGBoost/Lig
13
特征回溯与时间旅行
利用Flink的State TTL · 历史数据重放 · 归因结果修正
特征回溯时间旅行
14
归因结果可视化
Grafana仪表盘设计 · 归因因子分布图 · 实时归因趋势折线图
归因结果可视化Grafana
15
性能优化
算子链与资源并行度 · 数据倾斜处理 · 序列化优化（Kryo/Pojo）
性能优化算子链
16
单元测试与集成测试
Flink Test Harness · Mock数据源 · 归因逻辑验证
单元测试集成测试
17
生产环境部署
YARN/K8s部署模式 · 资源配额 · 日志与监控告警
生产环境部署YARN/K8s
18
归因模型版本管理
模型版本号与State兼容性 · A/B测试框架 · 灰度发布
归因模型版本管理State
19
实时特征存储
Redis/Alluxio集成 · 特征缓存策略 · 特征新鲜度保证
实时特征存储Redis/Alluxi…
20
坏样本归因案例
车险理赔欺诈归因 · 健康险逆选择归因 · 寿险长险退保归因
坏样本归因案例车险理赔欺诈归因
21
归因结果反馈闭环
归因结果回流至模型训练 · 主动学习样本筛选 · 模型迭代
归因结果反馈闭环归因结果回流至模…
22
Flink与AI平台集成
与TF Serving/MLflow… · 模型热加载 · 推理延迟优化
FlinkAI
23
归因数据血缘追踪
Atlas/DataHub集成 · 归因链路审计 · 合规性要求
归因数据血缘追踪Atlas/DataHu…
24
复杂事件处理进阶
多事件序列匹配 · 时间窗口约束 · 归因模式挖掘
复杂事件处理进阶多事件序列匹配
25
归因结果存储与检索
Elasticsearch索引设计 · 聚合查询 · 归因报告生成
归因结果存储检索
26
Flink CDC在归因中的应用
捕获数据库变更 · 实时特征更新 · 归因结果同步
FlinkCDC
27
归因模型可解释性
SHAP值计算 · LIME解释 · 归因因子重要性排序
归因模型可解释性SHAP
28
大规模归因作业调优
内存管理 · 网络缓冲 · 增量Checkpoint
大规模归因作业调…内存管理
29
归因结果异常检测
归因结果漂移监控 · 模型退化预警 · 自动回滚机制
归因结果异常检测归因结果漂移监控
30
课程总结与最佳实践
常见坑点 · 架构选型建议 · 未来趋势（Flink + AI）
课程总结最佳实践