首页
›
数据工程与实时数据平台
›
017-Flink实时计算
›
《Delta Lake 实时流批一体 Flink 方案》
VIP20
本课程属于:017-Flink实时计算
数据工程与实时数据平台 · 共 20 门相关课程,组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录
咨询 / 购买
Delta Lake 实时流批一体 Flink 方案
📚 共计 30 章节
点击此处阅读海量试读课程:100+行业、1000+细分领域
第 1 章
Delta Lake 前世今生
数据湖的演进脉络,Delta Lake 的诞生背景与核心特性概览,奠定技术基石。
数据湖
起源
第 2 章
环境搭建与入门
Spark 与 Delta Lake 集成,本地开发环境配置,创建并体验第一个 Delta 表。
环境
快速开始
第 3 章
ACID 事务原理
事务日志 Delta Log 深度解析,并发控制与乐观锁机制,版本管理核心设计。
事务
Delta Log
第 4 章
Schema 演化与强制
自动 Schema 演化策略,Schema 校验与强制约束,实际项目中的管理最佳实践。
Schema
演化
第 5 章
时间旅行与数据版本控制
时间旅行查询历史快照,数据回滚与恢复操作,Vacuum 清理历史版本机制。
时间旅行
版本
第 6 章
批处理读写
批量写入模式 Append/Overwrite,批量读取与分区裁剪,性能调优实用技巧。
批处理
性能
第 7 章
流式写入与 CDC
Structured Streaming 写入 Delta,Change Data Feed 原理,实时入湖最佳实践。
流式
CDC
第 8 章
Flink 集成基础
Flink 与 Delta Lake 连接器使用,Flink 读写 Delta 表,Checkpoint 与一致性保障。
Flink
集成
第 9 章
Flink 实时流批一体架构
Lambda 与 Kappa 架构对比,流批一体设计理念,Delta Lake 在架构中的核心角色。
架构
流批一体
第 10 章
Flink SQL 与 Delta
Flink SQL 创建/读写 Delta 表,Temporal Join 与 Lookup Join,SQL 化实时 ETL 实践。
Flink SQL
ETL
第 11 章
Delta Sharing 与数据共享
Delta Sharing 协议详解,搭建 Sharing 服务器,跨团队/跨组织数据协作方案。
共享
协作
第 12 章
性能优化
文件大小优化与 Z-Order,数据跳过 Data Skipping,动态分区修剪提升查询效率。
优化
Z-Order
第 13 章
运维与监控
Delta 表元数据管理,历史运行指标监控,常见问题排查与运维指南。
运维
监控
第 14 章
实战案例一:用户行为实时数仓
需求分析与架构设计,Flink + Delta 实现实时用户画像,构建实时数仓。
实战
用户画像
第 15 章
实战案例二:金融交易实时风控
高吞吐低延迟挑战,Delta ACID 保障交易一致性,回滚与审计追溯。
金融
风控
第 16 章
实战案例三:IoT 设备数据湖
海量时序数据入湖方案,Delta 分区策略设计,流批合并分析实践。
IoT
时序
第 17 章
与 Hive 集成
Delta 表暴露为 Hive 表,Spark/Flink 通过 Hive 元数据访问,迁移策略与方案。
Hive
集成
第 18 章
与 Presto/Trino 集成
Presto/Trino 查询 Delta 表,性能对比分析,适用场景与最佳实践。
Presto
Trino
第 19 章
安全与权限控制
表级/列级权限管理,与 Ranger/Atlas 集成,数据脱敏方案保障安全。
安全
权限
第 20 章
Delta Lake 2.0 新特性
Liquid Clustering 灵活布局,增量克隆加速开发,Checkpoint V2 性能提升。
2.0
新特性
第 21 章
Flink 1.14+ 新特性与 Delta
动态表 Dynamic Table 演进,异步 IO 与 Delta 集成,状态后端优化策略。
Flink 1.14
动态表
第 22 章
数据质量与校验
Delta CHECK 约束使用,数据质量框架 Deequ 集成,实时数据质量监控。
质量
Deequ
第 23 章
多模态数据支持
结构化、半结构化 JSON、非结构化图片/文档入湖方案与最佳实践。
多模态
非结构化
第 24 章
跨云/混合云部署
AWS S3 + Delta,Azure Data Lake Storage,GCP Cloud Storage 适配方案。
跨云
混合云
第 25 章
增量处理与流表关联
Stream-Stream Join 与 Stream-Table Join,Watermark 延迟数据处理策略。
流表关联
Watermark
第 26 章
数据湖的治理与目录
Unity Catalog、Apache Polaris 集成,自建元数据中心实现湖治理。
治理
目录
第 27 章
回压与背压处理
Flink 反压原理剖析,Delta 写入反压表现,优化策略与调优实践。
反压
调优
第 28 章
大规模集群调优
Spark/Flink 资源参数调优,Delta 写入并发控制,Shuffle 优化技巧。
集群
调优
第 29 章
故障恢复与 Exactly-Once
端到端 Exactly-Once 语义实现,Delta 事务回滚,Flink Checkpoint 对齐机制。
Exactly-Once
恢复
第 30 章
总结与展望
Delta Lake 生态全景回顾,与 Iceberg/Hudi 对比,未来 Lakehouse 与 AI 融合趋势。
总结
展望
所属VIP或分类
同VIP:Checkpoint机制深度解析与实战
同VIP:Flink-CDC-实时数据同步实战
同VIP:Flink-Exactly-Once-语义落地全解