VIP20

本课程属于：070-量化策略回测坏账率哨兵 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

量化回测坏账率哨兵Flink流处理实践

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

量化回测与坏账率哨兵的概念 · Flink在风控领域的价值 · 课程目标与前置知识

课程导论量化回测

Flink本地开发环境安装（JDK · Maven · Flink）

环境搭建Flink

Flink核心概念

DataStream API · Source/Transformat… · 并行度与Slot

Flink核心概念

坏账率指标定义

坏账率计算公式 · 时间窗口（滚动/滑动/会话） · 逾期口径（M1/M2/M3+）

坏账率指标定义坏账率计算公式

数据源设计

模拟交易数据生成器（Kafka Pr… · 交易事件Schema定义（JSON/… · 水位线（Watermark）策略

数据源设计Kafka

Flink SQL入门

Table & SQL API · 动态表概念 · 连续查询

实时ETL清洗

过滤无效交易 · 字段补齐 · 数据类型转换

KeyedStream与状态编程

KeyBy分组 · ValueState/MapStat… · 状态后端（RocksDB）配置

KeyedStream状态编程

事件时间与水位线

乱序数据处理 · Watermark生成方式（周期性/… · Allowed Lateness与侧…

事件时间水位线

窗口聚合实战

滚动窗口计算每小时坏账率 · 滑动窗口监控趋势 · 窗口函数（ReduceFunctio…

窗口聚合实战滚动窗口计算每小…

坏账率哨兵规则引擎

基于CEP（Complex Even… · Pattern API定义 · 连续逾期事件检测

坏账率哨兵规则引…CEP

动态规则更新

广播状态（Broadcast Sta… · 从外部配置中心（如Nacos/Red…

动态规则更新Broadcast

多流关联（Join）

交易流与用户画像流Join · Interval Join · Temporal Join实现实时特…

Join多流关联

HBase/MySQL维表异步查询 · 缓存策略（LRU） · 维表变更实时感知

维表关联HBase/MySQL

Flink Checkpoint与容错

Exactly-Once语义 · Checkpoint配置 · Savepoint手动触发与恢复

FlinkCheckpoint

反压监控与调优

反压原理 · Web UI监控指标 · 背压原因定位（数据倾斜/算子瓶颈）

反压监控调优

内存管理与调优

TaskManager内存模型 · 堆外内存 · RocksDB内存配置

内存管理调优

Flink on YARN/K8s部署

Session与Per-Job模式 · 资源参数配置 · 高可用（HA）设置

实时数仓分层

ODS/DWD/DWS/ADS分层设… · 坏账率指标在DWS层的物化 · OLAP引擎（ClickHouse/…

实时数仓分层ODS/DWD/DWS/…

Sink设计与输出

Kafka Sink · JDBC Sink（MySQL/Po… · 自定义Sink（Prometheus…

监控告警集成

Prometheus + Grafa… · 坏账率阈值告警规则 · 钉钉/飞书机器人通知

监控告警集成Prometheus

数据质量监控

数据延迟监控 · 重复数据去重（Deduplicati… · 数据完整性校验（DQC）

数据质量监控数据延迟监控

A/B测试与灰度发布

基于Sidecar模式的多版本Fli… · 流量路由策略 · 坏账率对比分析

回测与离线校准

将实时坏账率与离线Hive/Spar… · 偏差分析 · 校准策略

回测离线校准

使用JMeter/Flink Ben… · 压力测试报告解读 · 瓶颈定位

性能压测JMeter/Flink

生产环境踩坑实录

Checkpoint超时 · OOM · 数据倾斜

生产环境踩坑实录Checkpoint

Flink 2.0新特性

自适应调度 · 物化表 · 动态算子链

Flink0新特性

项目实战（上）

需求分析 · 架构设计 · 数据流图

项目实战需求分析

项目实战（中）

哨兵规则引擎实现 · 动态阈值更新 · 告警推送

项目实战哨兵规则引擎实现

项目实战（下）

全链路压测 · 性能调优 · 上线部署

项目实战全链路压测