VIP20

本课程属于：029-实时风控数据链路 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink实时规则特征计算

📚 共计 30 章节

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

Flink基础与环境搭建

Flink发展史、核心概念（DataStream/DataSet）、Flink vs Spark Streaming对比、本地开发环境搭建（IDEA + Maven + Flink集群）。

Flink编程模型与API

DataStream API基础、Source/Sink/Transformation算子详解、Flink程序骨架与执行流程。

时间语义与Watermark

EventTime/ProcessingTime/IngestionTime区别、Watermark原理与生成策略、如何处理乱序数据。

状态管理与容错机制

Keyed State与Operator State、状态后端（Memory/Fs/RocksDB）、Checkpoint与Savepoint原理。

滚动窗口、滑动窗口、会话窗口、窗口函数（ReduceFunction/AggregateFunction/ProcessWindowFunction）。

实时特征工程概述

什么是实时特征、特征分类（统计特征/时序特征/复杂特征）、实时特征计算架构设计。

Flink SQL与Table API

动态表概念、流式SQL查询、窗口聚合与Top-N、与DataStream API互操作。

CEP复杂事件处理

Pattern API基础、个体模式与组合模式、超时处理与事件选择器、实时风控场景实战。

实时规则引擎设计

规则定义与存储（MySQL/Redis）、规则热加载机制、规则匹配与动作执行。

特征存储与在线服务

特征存储选型（Redis/HBase/MySQL）、特征计算与存储分离架构、高并发低延迟特征查询。

实时特征计算案例-用户画像

用户标签实时更新、用户行为序列特征、实时用户分群。

实时特征计算案例-推荐系统

实时物品特征更新、用户实时兴趣向量、实时召回与排序特征。

实时特征计算案例-风控系统

设备指纹特征、交易行为特征、社交网络特征、实时规则评分卡。

Flink与Kafka集成

Kafka Source/Sink配置、Exactly-Once语义保证、Kafka消息格式与Schema Registry。

Flink与Redis集成

Redis Connector使用、特征缓存策略、Redis集群模式下的性能优化。

Flink与HBase集成

HBase Connector使用、宽表设计与特征存储、批量写入与异步查询。

Flink CDC实时数据同步

Flink CDC原理、MySQL CDC实战、实时增量同步与全量初始化。

Flink性能调优

并行度设置、算子链与资源隔离、反压检测与处理、内存模型调优。

Flink作业监控与告警

Metrics系统、自定义Reporter、作业重启策略、日志采集与分析。

Flink on YARN/K8s部署

YARN Session与Per-Job模式、K8s Native部署、资源动态分配。

实时特征计算数据质量保障

数据完整性校验、延迟监控与报警、特征回溯与补偿机制。

特征工程中的维表关联

异步IO维表关联、广播状态维表、维表缓存与更新策略。

复杂特征计算实战

滑动窗口计数特征、比率特征、熵特征、时序差分特征。

复杂特征实战

实时模型推理与特征服务

Flink与TensorFlow/PMML集成、在线模型服务架构、特征与模型版本管理。

多流Join与关联

双流Join、Interval Join、Temporal Join、维表Join实战。

Flink ML与实时特征

Flink ML Pipeline、实时特征标准化、实时特征选择。

实时特征计算平台建设

特征平台架构设计、特征注册中心、特征血缘追踪。

大规模特征计算优化

特征分片与并行计算、特征预计算与物化视图、特征计算资源隔离。

优化大规模

实时特征计算最佳实践

特征命名规范、特征版本管理、特征上线与回滚流程、A/B测试框架。

最佳实践规范

综合实战：实时风控特征计算平台

需求分析、架构设计、核心代码实现、性能压测与上线部署。

综合实战风控