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

Flink实时坏样本归因分析教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
什么是坏样本归因分析 · 实时归因与离线归因的区别 · Flink在归因场景中的优势
课程导论什么是坏样本归因…
02
环境准备
Flink集群搭建（Standalo… · JDK配置 · Maven项目初始化
环境准备Flink
03
数据源设计
模拟实时点击流数据 · 定义点击事件POJO · 使用DataStreamSource…
数据源设计模拟实时点击流数…
04
Watermark与时间语义
EventTime与Processi… · Watermark生成策略 · 乱序数据处理
Watermark时间语义
05
窗口机制
TumblingWindow · SlidingWindow · SessionWindow在归因中的…
窗口机制TumblingWind…
06
坏样本定义
什么是坏样本（异常点击 · 刷量 · 爬虫行为）
坏样本定义什么是坏样本
07
KeyBy与分区策略
按用户ID/设备ID进行KeyBy · 自定义分区器 · 解决数据倾斜
KeyBy分区策略
08
状态编程基础
ValueState · ListState · MapState在归因中的存储作用
状态编程基础ValueState
09
ProcessFunction实战
使用KeyedProcessFunc… · 定时器触发归因计算
ProcessFunct…KeyedProcess…
10
归因窗口聚合
将点击事件按归因窗口聚合 · 计算每个窗口内的坏样本得分
归因窗口聚合将点击事件按归因…
11
多流关联
使用Connect与CoProces… · 丰富归因特征
多流关联Connect
12
侧输出（SideOutput）
将正常样本与坏样本分流 · 侧输出标签定义与收集
SideOutput侧输出
13
CEP复杂事件处理
使用Flink CEP定义坏样本模式… · 模式匹配输出
CEP复杂事件处理
14
归因规则引擎
基于配置表动态加载归因规则 · 广播状态（BroadcastStat…
归因规则引擎基于配置表动态加…
15
特征工程
实时提取统计特征（均值 · 方差 · 频次）
特征工程实时提取统计特征
16
模型推理集成
在Flink中调用预训练模型（ONN… · 异步IO提升推理吞吐
模型推理集成Flink
17
归因结果输出
将归因结果写入Kafka · 定义Avro序列化Schema · 保证Exactly-Once语义
归因结果输出Kafka
18
维表关联
使用AsyncIO关联MySQL维表… · 缓存策略优化
维表关联AsyncIO
19
Checkpoint与容错
Checkpoint配置 · Savepoint手动触发 · 故障恢复后归因状态一致性
Checkpoint容错
20
性能调优
并行度设置 · 算子链优化 · 缓冲区调优
性能调优并行度设置
21
反压监控
反压产生原因 · WebUI监控反压 · 通过背压采样定位瓶颈
反压监控反压产生原因
22
SQL方式归因
使用Flink SQL定义归因视图 · TUMBLE窗口聚合 · 维表JOIN
SQL方式归因
23
Table API归因
使用Table API进行归因特征计… · toRetractStream输出变…
TableAPI
24
实时数仓分层
ODS/DWD/DWS/ADS在归因… · 数据流转链路
实时数仓分层ODS/DWD/DWS/…
25
归因指标看板
将归因结果写入ClickHouse · 使用Grafana搭建实时归因监控看…
归因指标看板ClickHouse
26
A/B测试框架
在Flink中实现归因策略A/B分流 · 使用RandomSplit或自定义S…
A/B测试框架
27
数据回溯
使用Savepoint进行历史数据回… · 对比新旧规则效果
数据回溯Savepoint
28
生产部署
Flink on YARN/K8s部… · 资源参数配置 · 日志采集与告警
生产部署Flink
29
案例实战一
电商平台恶意刷单归因分析（从数据接入…
案例实战一电商平台恶意刷单…
30
案例实战二
广告点击反作弊归因分析（CEP模式匹…
案例实战二CEP