01
金融数据仓库概述
金融行业数据特点 · 数据仓库核心概念 · 实时与批量处理对比
基础概念
02
Lambda架构详解
Lambda架构原理 · 批处理层 · 速度层 · 服务层
架构经典
03
Kappa架构详解
Kappa架构原理 · 与Lambda对比 · 适用场景
架构流式
04
混合架构设计原则
数据一致性 · 容错性 · 可扩展性 · 成本控制
设计原则
05
实时数据采集技术
Kafka核心概念 · Topic与Partition · 生产者与消费者
Kafka采集
06
Kafka高级特性
消息可靠性 · Exactly-Once语义 · Kafka Connect与Streams
Kafka高级
07
批量数据采集技术
Sqoop与DataX对比 · 全量同步与增量同步
批量同步
08
实时计算引擎Flink
Flink架构 · DataStream API · 时间语义与Watermark
Flink实时
09
Flink状态管理与容错
状态后端 · Checkpoint与Savepoint · 端到端Exactly-Once
Flink容错
10
Flink SQL与实时数仓
动态表 · 连续查询 · Flink SQL实战案例
Flink SQL数仓
11
批量计算引擎Spark
Spark架构 · RDD与DataFrame · Spark SQL
Spark批量
12
Spark性能优化
Shuffle调优 · 内存管理 · 动态资源分配
Spark优化
13
数据湖技术Iceberg
Iceberg表格式 · ACID事务 · 时间旅行
数据湖Iceberg
14
数据湖技术Hudi
Hudi表类型(COW/MOR) · 增量查询 · 与Flink集成
数据湖Hudi
15
实时数仓分层设计
ODS · DWD · DWS · ADS分层策略
分层实时
16
批量数仓分层设计
STG · ODS · DWD · DWS · DM分层策略
分层批量
17
实时与批量数据一致性
双流Join · 延迟数据处理 · 回溯补偿机制
一致性混合
18
元数据管理
Apache Atlas · 数据血缘 · 数据目录
元数据治理
19
数据质量监控
实时监控指标 · 批量校验规则 · 异常告警
质量监控
20
数据安全与权限
Kerberos认证 · Ranger权限控制 · 数据脱敏
安全权限
21
实时ETL实战
从Kafka到Flink的清洗与转换
ETL实时
22
批量ETL实战
从HDFS到Spark的聚合与建模
ETL批量
23
实时OLAP引擎ClickHouse
列式存储 · MergeTree引擎 · 分布式查询
OLAPClickHouse
24
批量OLAP引擎Doris
MPP架构 · Rollup表 · 物化视图
OLAPDoris
25
实时指标计算
Flink CEP复杂事件处理 · 实时大屏案例
指标CEP
26
批量报表生成
Spark SQL生成T+1报表 · 调度系统Airflow
报表调度
27
混合查询引擎Presto/Trino
联邦查询 · 跨数据源分析
查询Presto
28
数据湖仓一体架构
Lakehouse概念 · Delta Lake与Iceberg对比
湖仓一体架构
29
金融风控场景实战
实时反欺诈 · 批量信用评分模型
风控实战
30
金融交易分析场景实战
实时交易监控 · 批量交易对账
交易实战