01
归因分析概述
什么是用户事件归因、归因在业务中的价值、常见归因模型介绍（首次点击、末次点击、线性归因、时间衰减归因、位置归因）。
归因基础模型概览
02
实时计算基础
实时计算与离线计算的区别、实时计算的应用场景、技术选型（Flink、Spark Streaming、Kafka Streams）。
流计算FlinkKafka
03
事件数据模型设计
用户事件的定义与分类、事件属性设计原则、事件时间与处理时间、事件ID与用户ID的关联。
数据建模ID关联
04
Kafka消息队列实战
Kafka核心概念（Topic、Partition、Consumer Group）、安装配置、生产者与消费者API、消息可靠性保证。
消息队列可靠性
05
Flink入门与核心概念
Flink架构与组件、DataStream API基础、时间语义（Event Time、Processing Time）、Watermark机制。
FlinkWatermark
06
Flink状态管理与容错
状态类型（ValueState、ListState、MapState）、Checkpoint与Savepoint、Exactly-Once语义实现。
状态后端容错
07
实时ETL与数据清洗
数据格式标准化、脏数据过滤与异常处理、字段补全与维度关联、实时数据质量监控。
ETL数据质量
08
首次点击归因模型实现
模型原理与适用场景、Flink实现首次点击归因、状态存储与过期策略、业务效果评估。
首次点击Flink
09
末次点击归因模型实现
模型原理与适用场景、Flink实现末次点击归因、与首次点击对比分析、实际案例分享。
末次点击对比
10
线性归因模型实现
模型原理与适用场景、权重分配算法、Flink实现线性归因、多触点场景处理。
线性归因权重
11
时间衰减归因模型实现
衰减函数设计（线性衰减、指数衰减）、Flink实现时间衰减归因、衰减参数调优。
时间衰减调优
12
位置归因模型实现
U型归因模型原理、Flink实现位置归因、自定义位置权重、与行业标准对比。
U型归因位置权重
13
自定义归因模型设计
业务需求分析、模型参数化设计、Flink动态配置加载、模型热更新方案。
自定义热更新
14
归因结果存储与查询
结果表结构设计、HBase/Redis存储方案、ClickHouse实时查询、数据TTL策略。
存储ClickHouse
15
实时效果指标计算
转化率、ROI、归因贡献度、归因置信度、指标计算Flink实现。
指标ROI
16
多模型对比分析
A/B测试框架设计、对比指标定义、可视化对比看板、模型选择决策树。
A/B测试决策树
17
归因数据可视化
ECharts/Highcharts集成、桑基图展示用户路径、漏斗图展示转化、实时大屏设计。
可视化桑基图
18
反作弊与异常检测
刷量行为识别、异常流量过滤、归因结果校验、实时告警机制。
反作弊告警
19
实时归因系统架构设计
整体架构分层（采集层、计算层、存储层、应用层）、高可用设计、水平扩展方案。
架构高可用
20
性能优化与调优
Flink并行度设置、Kafka分区优化、状态后端选择（RocksDB vs Heap）、内存管理。
性能RocksDB
21
数据血缘与回溯
归因链路追踪、数据血缘记录、历史数据回溯计算、数据一致性校验。
血缘回溯
22
多端用户身份打通
设备ID、登录ID、Cookie ID的关联、ID Mapping方案、实时合并策略。
ID Mapping打通
23
跨渠道归因分析
线上渠道（SEM、SEO、信息流）、线下渠道（门店、地推）、跨渠道归因挑战。
跨渠道线上线下
24
归因效果评估体系
评估指标设计（准确率、覆盖率、时效性）、评估数据集构建、自动化评估流程。
评估自动化
25
实时归因在广告投放中的应用
出价策略优化、预算分配、创意优选、实时反馈闭环。
广告出价
26
实时归因在用户增长中的应用
渠道质量评估、用户分群、激活归因、留存归因。
用户增长留存
27
实时归因在产品运营中的应用
功能使用归因、活动效果评估、用户路径优化、个性化推荐。
产品运营推荐
28
监控与运维
Flink作业监控（延迟、吞吐量、背压）、Kafka消费延迟监控、告警规则配置、日志收集与分析。
监控运维
29
案例实战：电商归因系统
需求分析、技术选型、核心代码实现、效果展示。
电商实战
30
案例实战：内容平台归因系统
需求分析、技术选型、核心代码实现、效果展示。
内容平台实战