VIP20
本课程属于：029-实时风控数据链路 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

低延迟Join在风控中的用法

📚 共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
低延迟Join概述
风控场景下的实时关联需求、Join延迟的代价、低延迟Join的核心挑战。
实时关联延迟代价
02
Flink State与Join基础
Flink KeyedState简介、ValueState/MapState/ListState、Flink Join算子概览（Window Join、Interval Join、Temporal Join）。
KeyedState算子概览
03
Interval Join原理与配置
Interval Join的时间边界、上下界配置、数据乱序容忍度、状态清理策略。
时间边界乱序容忍
04
Interval Join实战
风控黑白名单实时关联、交易与设备指纹Join、代码示例与性能调优。
黑白名单设备指纹
05
Temporal Join（时态表Join）
时态表概念、事件时间与处理时间语义、For SYSTEM_TIME AS OF 语法、风控场景中的缓慢变化维表关联。
时态表缓慢变化维
06
Temporal Join实战
用户画像实时补全、IP地理信息关联、代码示例与状态大小控制。
画像补全IP地理
07
Window Join（窗口Join）
滚动窗口Join、滑动窗口Join、会话窗口Join、风控中的短窗口聚合关联。
滚动窗口会话窗口
08
Window Join实战
同一用户5分钟内交易与登录行为关联、代码示例、窗口迟到数据处理。
交易登录迟到数据
09
广播状态（Broadcast State）模式
BroadcastStream与DataStream连接、BroadcastProcessFunction、风控规则动态下发与实时关联。
广播状态动态规则
10
广播状态实战
动态黑白名单更新、规则引擎实时匹配、代码示例与状态一致性保障。
黑白更新规则引擎
11
异步I/O（Async I/O）与Join
AsyncDataStream API、外部存储（Redis/HBase）关联、异步请求超时与并发控制。
Async I/ORedis/HBase
12
异步I/O实战
实时查询Redis中的设备指纹库、代码示例、线程池配置与背压处理。
设备指纹背压处理
13
维表Join优化策略
LRU缓存、TTL设置、预加载与热更新、异步与批量查询结合。
LRU缓存批量查询
14
双流Join的数据倾斜处理
KeyBy热点问题、Salting技术、MiniBatch与LocalGlobal优化。
数据倾斜Salting
15
状态后端选择与调优
RocksDB vs Heap StateBackend、RocksDB调优参数、增量Checkpoint。
RocksDB增量Checkpoint
16
Checkpoint与状态一致性
Exactly-Once语义、Checkpoint配置、状态恢复与容错。
Exactly-Once容错
17
Join中的Watermark与时间语义
Watermark生成策略、Idleness处理、迟到数据管理。
Watermark迟到数据
18
SQL Join在风控中的应用
Flink SQL Join语法、双流Join SQL化、维表Join SQL（Temporal Join）。
Flink SQL维表Join
19
SQL Join实战
风控事件流与维表流SQL关联、代码示例、SQL Hints优化。
SQL关联Hints优化
20
多流Join的复杂场景
三流Join实现、事件序列拼接、风控链路追踪。
三流Join链路追踪
21
Join结果延迟监控
LatencyMarker、Metrics监控、告警规则设置。
延迟监控告警
22
Join性能压测方法论
数据构造、压力模型、瓶颈分析、调优闭环。
压测瓶颈分析
23
Join与CEP（复杂事件处理）结合
CEP模式匹配中的Join需求、风控序列检测。
CEP序列检测
24
Join在反欺诈场景中的案例
盗卡交易检测、设备异常登录关联、团伙欺诈识别。
反欺诈团伙识别
25
Join在信贷风控中的案例
多头借贷关联、用户信息一致性校验、黑产团伙挖掘。
信贷风控多头借贷
26
Join在实时营销风控中的案例
秒杀活动防刷、优惠券套现识别、拉新作弊检测。
营销风控防刷
27
Join在内容风控中的案例
垃圾评论用户关联、恶意注册检测、水军账号识别。
内容风控水军识别
28
Join在支付风控中的案例
交易对手关联、资金链路追踪、洗钱模式识别。
支付风控洗钱识别
29
Join在物联网风控中的案例
设备指纹关联、异常登录地理位置校验、设备更换检测。
物联网设备指纹
30
低延迟Join的未来趋势
Flink新特性（版本演进）、云原生部署、Serverless Flink、AI辅助Join优化。
云原生Serverless