实时计算与极速分析架构

我要预订

咨询电话：027-5111 9925 , 027-5111 9926手机：18971071887邮箱：Service@mingketang.com

课程背景

离线数仓无法满足秒级响应的业务需求。Flink作为流批一体的事实标准，其状态管理、Checkpoint、Window机制是实时开发的核心。与此同时，极速OLAP引擎（ClickHouse/Doris）、联邦查询引擎（Presto/Trino）和全文检索引擎（Elasticsearch）构成了实时分析链路的关键组件。本课程系统讲解Flink运行时架构、状态后端、Watermark处理，并结合ClickHouse的向量化执行、Presto的跨源联邦查询、Elasticsearch的倒排索引，培养学员构建实时大屏与多引擎协同分析平台的能力。

课程收益

深入理解Flink运行时架构（JobManager/TaskManager、Slot、ExecutionGraph）

掌握反压定位、状态后端（RocksDB）调优及Checkpoint配置

熟练使用Window、Watermark处理乱序事件，实现事件时间语义

能够使用Flink SQL构建实时数仓，完成Kafka CDC消费及双流Join

掌握ClickHouse列式存储、MergeTree索引及物化视图优化

熟练使用Trino/Presto跨Hive、MySQL、ES等数据源进行联邦查询

理解Elasticsearch倒排索引、分片路由与脑裂预防

课程特色

流批一体实战：Flink SQL + Kafka + CDC全链路

多引擎协同：Flink入ClickHouse，Trino联邦查询

大屏驱动：实时聚合写入OLAP引擎，秒级响应

生产排障：反压、Checkpoint失败、脑裂等真实案例

课程对象

实时计算工程师、数据开发工程师

数据平台架构师、OLAP工程师

希望从Spark Streaming转向Flink的开发者

前置知识：Java基础，了解Kafka及SQL。建议先修《课程一、二》或具备数据集成与数仓基础。

课程大纲

单元1：流批一体引擎核心机制（Flink）（3天）

第1课：Flink运行时架构（1天）

章节1：分布式执行图（StreamGraph → JobGraph → ExecutionGraph）与Task Slot资源隔离

章节2：反压的产生机制与网络缓冲排障（使用Web UI或Metrics）

实践：提交一个压测任务，故意限速下游，观察反压传播

第2课：状态管理与时间语义（1天）

章节1：State状态后端（Heap vs RocksDB）内存模型与大状态调优

章节2：Checkpoint容错屏障机制与全局一致性保障（Barrier对齐、非对齐）

章节3：Window窗口切分（滚动、滑动、会话）与Watermark乱序事件处理

实践：实现一个基于事件时间的会话窗口聚合，测试乱序数据

第3课：实时数仓实战（1天）

章节1：Flink SQL在Kafka数据源上的CDC消费与双流Join（维表Join、Interval Join）

章节2：端到端Kafka-Flink-Sink Exactly-Once语义的实现（两阶段提交）

实践：构建实时订单宽表，写入ClickHouse

单元2：极速分析与联邦查询引擎（4天）

第1课：极速OLAP引擎（ClickHouse/Doris）（1.5天）

章节1：列式存储的物理块结构与向量化执行引擎

章节2：MergeTree/Aggregate引擎机制与稀疏索引原理

章节3：大宽表高并发查询优化与物化视图应用

实践：设计ClickHouse表，导入亿级数据，对比不同索引下的查询性能

第2课：联邦查询引擎（Presto/Trino）（1.5天）

章节1：MPP架构解析与内存计算管道模型

章节2：跨数据源（Hive + MySQL + Elasticsearch）的联合查询配置（Catalog、Connector）

实践：配置Trino连接Hive和MySQL，执行跨源Join

第3课：全文检索与日志分析（Elasticsearch）（1天）

章节1：倒排索引结构与Lucene底层机制

章节2：分片与副本路由策略及脑裂预防（discovery.zen.minimum_master_nodes）

实践：接入应用日志到ES，执行全文搜索与聚合分析

模块核心实验：多引擎协同的实时大屏与跨源分析

利用Flink读取Kafka实时流进行状态聚合写入ClickHouse提供大屏秒级响应；同时使用Trino构建联邦查询，在一条SQL中联合ClickHouse的实时数据与Hive的离线历史数据。

杨老师

大数据&云计算资深实战派专家 杨文清

【专业资质】

20年企业应用与研发经验

拥有2项人工智能相关国家发明专利

中国联通集团深度培训资深讲师

AWS 云计算认证专家

曾任 IBM中国华南区高级咨询顾问

曾任华为Cloud BU高级架构师

曾任广州云宏研发总监

曾任广州智数x-Lab实验室首席科学家

武汉大学计算机科学专业硕士，22年企业应用与研发经验，曾就职于IBM、华为等大型企业，十年华为工作经验，任职华为高级架构师。

并先后担任过知名互联网公司研发总监和智数xLab实验室首席数据科学家。亚马逊云计算认证专家、VMware国际认证讲师。

中国联通集团引擎计划深度培训资深讲师（主讲Docker&K8S、Hadoop、Spark、机器学习、深度学习），对云计算、大数据有深刻的理解，主导过多项国家级大数据项目，并拥有人工智能方面的若干项国家专利。

【实战经验】

IBM中国华南区高级咨询顾问，期间曾参与公安、金融、通信、制造等行业云计算产品方案研发，为多个大型企业提供IT基础建设咨询。

华为Cloud BU高级架构师，聚焦于是云服务产业端到端管理的经营单元，负责构建云服务竞争力，对云服务的客户满意度和商业成功负责。

广州云宏研发总监，带领团队研发了WinCloud云计算管理平台、CnWare云计算操作系统，产品覆盖运营商、公安、金融、政府机关、教育、医疗等多个领域，虚拟机数量超过50万。受到国家、省市领导和专家的肯定和好评。

【项目实战经验】

国产云操作系统 (CnWare) 研发总监

云宏：参与主导公司核心产品WinCloud云管理平台建设，是当前市场上唯一可以同时管理小型机虚拟化、x86虚拟化和arm架构虚拟化的云管理平台；CnWare是唯一的国产云操作系统，对标VmWare，内容包括虚拟化管理中心、虚拟化中间件和虚拟化引擎3部分，实现了全生态全流程的虚拟化覆盖。该产品在中国电信集团采购入围时获得总分第一的成绩。

构建智慧水务AI预警平台 实验室首席科学家

智数信息：任职xLab实验室首席科学家，负责公司前瞻性技术的基础研究，并实现新技术在项目中的落地。期间将以太坊区块链技术应用到了现有的食品溯源系统；协助研发团队在智慧城市管理项目实现了物联网数据的全自动处理过程；协助研发团队将自动化运营引入到港珠澳大桥综合管理系统。作为公司首席科学家，对基础研究的标准化（选型、可行性、研究、应用）过程制定了完整的过程管理。

港珠澳大桥综合业务管理系统 首席架构师

构建综合业务管理平台，为大桥的物流、应急管理、通关提供坚实的数据支撑，提升信息化效率。

宝安智慧水务 研发总监|架构师

实现了物联网数据的全自动处理、自定义指标预警、自助式数据可视化分析，用于企业污水排放监控 。

财政信息一体化 后端架构师

建设大数据平台与业务系统，实现数据整合、可视化、异常数据监控与财政指标智能预测 。

电信经营分析系统 项目经理 / 主导设计

用数据仓库技术与可视化，对电信企业的内部和外部数据进行综合分析处理，生成运营指标 。

【擅长领域】

核心技术/技术管理/架构能力；热衷于技术驱动业务，致力于将新技术转化为高效的生产力。

【讲师优势】

拥有超过20年一线实战经验的复合型技术专家与资深讲师。兼具华为与IBM的顶级企业架构视野，以及将前沿技术从0到1成功产品化的落地能力。

多年来始终坚持在技术一线参与核心研发工作。 对技术在真实业务场景中的痛点、难点和选型权衡有极为深刻的理解，确保了其教学内容与业界最新实践紧密结合，直击问题本质。

【主讲项目/课程(部分)】可根据企业需求组合成不同深度的技术训练营。

《数据科学基础》

《Python编程：从入门到数据处理》

《数据分析思维》

《数据可视化技术与分析报告撰写》

《机器学习核心》

《机器学习经典算法与理论》

《集成学习实战：深入解析XGBoost等模型》

《基于Spark的海量数据分析与机器学习》

《深度学习进阶》

《深度学习框架PyTorch：入门与应用》

《卷积神经网络(CNN)与循环神经网络(LSTM)实战》

《LLM基础：注意力机制(Transform)实战》

《AI技术工程化》

《AI应用基础：提示词工程》

《RAG（检索增强生成）开发实战》

《AI Agent（智能体）开发实战》

《AI 行业应用案例分析》

【授课风格】

1.实战派落地教学，拒绝空谈赋能​

课程内容紧密结合主导的大型项目真实经验，案例翔实，以真实场景、真实案例、真实打法为核心支撑，全干货、全落地，拒绝空谈理论。

2.架构师全局视野，搭建体系能力​

跳出单一操作教学，深度拆解业务底层逻辑与运营架构，溯源打法设计原理，助力学员构建系统化、可迭代的完整业务体系。

3.通透化授学思维，实现举一反三​

依托全域实战经验拆解核心本质，沉淀通用方法论，助力学员举一反三、灵活复用、全域落地。真正实现学一项、通一类、用全域。

【服务客户(部分)】

运营商：联通集团总部、中国电信河南有限公司、中国电信山东有限公司、中国电信江苏有限公司、中国电信重庆有限公司、中国联通广东有限公司、中国联通福建有限公司、中国联通广西有限公司、中国联通上海有限公司、中国联通陕西有限公司、中国联通河北有限公司、中国联通云南有限公司、中国联通重庆有限公司、中国联通四川有限公司、中国联通青海有限公司、中国移动江苏有限公司、中国移动云南有限公司、中国移动浙江有限公司、中国移动河南有限公司、中国移动四川有限公司、中国移动吉林有限公司、中国移动湖北有限公司、中国移动安徽有限公司等

IT公司：华为、腾讯云、IBM、DELL、航天科工、中国航天、TaTa集团、中科曙光、龙芯中科、航天云网、航天科工、联想集团、腾讯云、蓝盾、浩云科技、润乾等

能源：国家电网（湖北省、浙江省、成都等）、南方电网、广东能源集团、江苏核电、国家电投、国网电科院、国能集团长源电力、中煤电力等

银行：中国银行广州分行、招商银行武汉分行、中国银行江苏分行、农业银行荆州分行、交通银行贵州分行、交通银行武汉分行、建设银行广州分行、中国邮政储蓄银行长沙分行、中国邮政储蓄银行南昌分行、平安银行杭州分行、广发银行广州分行、兴业银行、北京银行、工商银行、工银投资、宁波银行等

我要预订

咨询电话：027-5111 9925 , 027-5111 9926手机：18971071887邮箱：Service@mingketang.com