流批一体架构和实战

 离线数仓技术架构和技术栈介绍

 实时数仓架构架构和技术栈介绍

 流批一体架构的优点

 流批一体架构解决方案

 流批一体架构技术栈详解

 流批一体数据架构的设计

 流批一体数据摄取、整合、处理和应用的解决方案

 流批一体平台架构在互联的实战

 美团流批一体平台架构分享

基于Flink流批一体数仓案例实战

 滴滴基于Flink实现复杂事件处理的案例分享

- Flink+CEP

- Flink状态管理

- Flink运维和优化

- Flink容错机制

- Flink反压机制

- Flink任务的双链路备用

 阿里巴巴基于Flink实时统计案例分享

- 阿里双十一实时架构分享

- 双流数据Join处理

- Flink流失实仓架构详解

- FlinkCEP实时规则引擎详解

Flink技术栈介绍

 FlinkTableAPI介绍

 FlinkSQL介绍

 FlinkCDCConnect介绍

 FlinkCEP复杂事件处理

 FlinkGelly图计算应用

 FlinkML机器学习应用

 PyFlink数据分析和挖掘介绍

 Flink Metrics 与监控

Flink有状态的计算、态管理和容错

 什么是有状态计算

 有状态计算中的数据一致性挑战

 理解state状态

 Operator State 的使用及Redistribute

 Keyed State的使用与Redistribute

 Broadcast State的使用

 Checkpoint核心原理剖析

 Checkpoint使用条件及使用步骤

 Checkpoint相关配置及重启策略

 Savepoint的触发、Job恢复及删除

FlinkDataStreamAPI原理和实战

 DataStream API介绍与使用

 DataStream编程模型

 DataStream类型与转换

 Pipeline与StreamGraph转换

 Transformation

 时间概念与Watermark

 Windows窗口计算和多流合并

 作业链和资源组

 Asynchronous I/O异步API

 Asynchronous I/O异步原理

FlinkDataSetAPI介绍和实战

 DataSet API，Transformation

 迭代计算

 广播变量与分布式缓存

 语义注解

 DataSetUtils工具类

Flink TableAPI& SQL实战

 Flink table API原理和使用

 Flink SQL原理和使用

 TableEnviroment原理和使用

 Table Connector注册机制和使用

 TimeStamp与Watermark原理和实战

 Temporal Tables原理实战

 多表关联实战

 与Hive的集成实战

 自定义TableSource、Table Sink和Table Factory实战

 Flink SQL Catalog原理

 项目实战：基于Flink SQL实现数据统计分析

FlinkConnector介绍和实战

 Flink Connector数据源

 FlinkKafkaSource序列化、消费模式

 FlinkKafkaSource容错、动态分区及topic

 FlinkKafkaSink序列化、配置、分区与容错

 自定义Source和Sink

Flink监控和优化

 Flink Metric使用介绍

 FlinkRestAPI介绍和使用

 Backpressure监控与优化

 Checkpointing监控与优化

 Flink内存管理和优化

 窗口和事件事件调试

 HistoryServer服务介绍

Flink实时数据仓库项目实战

 项目导入IDEA和配置

 项目需求和技术架构介绍

 数据摄取模块介绍

- 离线数据摄取（Sqoop）

- 实时数据摄取（mysql+Canal+Kafka）

 实时数据处理模块

- 实时数据仓库分层架构

- Flink+Kafka+Clickhouse数据处理

- 维度和指标梳理

- Clickhouse的SQL接口

- Flink SQL 数据统计和分析

 数据展示模块介绍

 项目运行和效果展示