VIP20

本课程属于：046-反欺诈图谱阈值分层试验 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink特征服务团伙识别实战指南

共计 30 章节

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

团伙识别业务背景 · Flink在反欺诈中的定位 · 特征服务架构总览

课程导论团伙识别业务背景

Flink开发环境搭建

JDK配置 · Maven项目创建 · Flink本地模式启动

Flink开发环境搭建

Flink DataStream API基础

Source · Transformation · Sink概念

FlinkDataStream

Flink时间语义与Watermark

EventTime · ProcessingTime · IngestionTime区别

Flink状态编程

KeyedState与Operato… · ValueState/ListSta… · 状态后端配置

Flink状态编程

Flink Checkpoint与容错机制

Checkpoint原理 · Exactly-Once语义 · Savepoint手动恢复

FlinkCheckpoint

Flink Table & SQL API

TableEnvironment创建 · 动态表概念 · SQL查询与CDC集成

特征工程基础

特征分类（统计特征 · 时序特征 · 图特征）

特征工程基础特征分类

Flink特征计算框架设计

特征计算Pipeline · 维表关联（AsyncIO） · 特征时效性保障

Flink特征计算框架设计

实时特征存储与读取

Redis连接器配置 · HBase连接器配置 · 特征数据TTL策略

实时特征存储读取

团伙识别业务建模

团伙定义 · 关系图谱构建 · 常见团伙模式（设备聚集

团伙识别业务建模团伙定义

图计算基础与Flink Gelly

图论基础 · Gelly API介绍 · PageRank与连通分量算法

基于Flink的实时图特征提取

二跳邻居统计 · 共同邻居计算 · Jaccard相似度实时计算

关系网络构建

事件流到图边的转换 · 边属性聚合 · 窗口化图构建策略

关系网络构建事件流到图边的转…

特征服务API设计

RESTful接口设计 · 特征查询路由 · 批量特征获取与缓存策略

API特征服务

Flink与Kafka集成

Kafka Source/Sink配… · 消息序列化 · 消费偏移量管理

Flink与Redis集成

Redis Sink实现特征写入 · Redis Lookup Join实…

Flink与HBase集成

HBase Sink实现特征持久化 · HBase维表关联优化

Flink CEP复杂事件处理

Pattern API定义 · 个体模式与组合模式 · 团伙行为序列匹配

基于CEP的团伙行为检测

登录-转账-提现模式识别 · 时间窗口约束 · 阈值告警

Flink ML机器学习库

FlinkML Pipeline · 特征向量化 · 在线聚类（Streaming K-M…

实时异常检测模型

孤立森林算法原理 · Flink实现孤立森林 · 模型更新与部署

实时异常检测模型孤立森林算法原理

特征重要性评估

基于Flink的在线特征统计 · 信息增益计算 · 特征筛选策略

特征重要性评估Flink

多源特征融合

设备指纹特征 · 行为序列特征 · 关系图特征

多源特征融合设备指纹特征

特征服务性能优化

算子链优化 · 并行度调优 · 反压监控与处理

特征服务性能优化算子链优化

Flink作业监控与告警

Metrics系统 · 自定义Reporter · Prometheus+Grafana…

Flink作业监控

团伙识别规则引擎

Drools/Flink CEP规则… · 规则热更新 · 规则冲突检测

团伙识别规则引擎Drools/Flink

实时特征服务高可用设计

主备切换 · 特征数据一致性 · 降级与熔断策略

实时特征服务高可…主备切换

实战案例一

设备聚集团伙识别——基于Flink实…

实战案例一Flink

实战案例二

支付链团伙识别——基于Flink C…

实战案例二Flink