- 详情
- 目录
- 套餐4
- 咨询3
- 评价28
第1章 初识Flink
- 1-1 课程导学 试听23分钟21秒
- 1-2 ***学前必读***(助你平稳踩坑,畅学无忧,课程学习与解决问题指南) 试听25分钟
- 1-3 课程目录27分钟22秒
- 1-4 Flink概述13分钟25秒
- 1-5 Flink Layered API29分钟18秒
- 1-6 Flink运行多样化17分钟48秒
- 1-7 业界流处理框架对比12分钟06秒
- 1-8 Flink Use Cases28分钟23秒
- 1-9 Flink发展趋势14分钟55秒
- 1-10 如何以正确的姿势来学习Flink13分钟28秒
第2章 快速上手开发第一个Flink应用程序
- 2-1 课程目录 试听11分钟10秒
- 2-2 开发环境准备之JDK安装23分钟29秒
- 2-3 开发环境准备之Maven安装16分钟09秒
- 2-4 开发环境准备之IDEA安装25分钟11秒
- 2-5 Flink批处理应用开发之需求描述15分钟47秒
- 2-6 Flink批处理应用Java开发之环境准备20分钟15秒
- 2-7 Flink批处理应用开发之八股文编程26分钟02秒
- 2-8 Flink批处理应用Java开发之功能实现17分钟26秒
- 2-9 Flink批处理应用Scala开发之环境准备29分钟56秒
- 2-10 Flink批处理应用Scala开发之功能实现20分钟08秒
- 2-11 使用Java和Scala开发Flink应用程序对比15分钟38秒
- 2-12 Flink实时处理应用Java开发之功能实现26分钟48秒
- 2-13 Flink实时处理应用Java开发之代码重构13分钟02秒
- 2-14 Flink实时处理应用Scala开发之代码重构25分钟35秒
- 2-15 开发过程中依赖的注意事项24分钟34秒
第3章 编程模型及核心概念
- 3-1 课程目录25分钟37秒
- 3-2 核心概念概述18分钟54秒
- 3-3 DataSet和DataStream29分钟29秒
- 3-4 Flink编程模型11分钟31秒
- 3-5 延迟执行22分钟16秒
- 3-6 指定key之Tuple25分钟29秒
- 3-7 指定key之字段表达式23分钟51秒
- 3-8 指定key之key选择器函数15分钟43秒
- 3-9 指定转换函数14分钟14秒
- 3-10 Flink支持的数据类型26分钟08秒
第4章 DataSet API编程
- 4-1 课程目录14分钟49秒
- 4-2 DataSet API开发概述16分钟37秒
- 4-3 Flink综合Java和Scala开发的项目构建creenflow27分钟51秒
- 4-4 Data Source宏观概述10分钟13秒
- 4-5 从集合创建DataSet之Scala实现16分钟38秒
- 4-6 从集合创建DataSet之Java实现29分钟32秒
- 4-7 从文件或者文件夹创建DataSet之Scala实现27分钟37秒
- 4-8 从文件或者文件夹创建DataSet之Java实现28分钟22秒
- 4-9 从csv文件创建Dataset之Scala实现25分钟24秒
- 4-10 从递归文件夹的内容创建DataSet之Scala实现13分钟21秒
- 4-11 从压缩文件中创建DataSet之Scala实现22分钟14秒
- 4-12 Transformation概述10分钟56秒
- 4-13 Transformation函数map之Scala实现13分钟51秒
- 4-14 Transformation函数map之Java实现22分钟21秒
- 4-15 Transformation函数filter之Scala实现10分钟42秒
- 4-16 Transformation函数filter之Java实现26分钟01秒
- 4-17 Transformation函数mapPartition之Scala实现15分钟25秒
- 4-18 Transformation函数mapPartition之Java实现23分钟03秒
- 4-19 Transformation函数first之Scala实现29分钟04秒
- 4-20 Transformation函数first之Java实现28分钟34秒
- 4-21 Transformation函数flatMap之Scala实现10分钟36秒
- 4-22 Transformation函数flatMap之Java实现25分钟44秒
- 4-23 Transformation函数distinct之Scala和Java实现23分钟48秒
- 4-24 Transformation函数join之Scala实现26分钟55秒
- 4-25 Transformation函数outerJoin之Scala实现20分钟44秒
- 4-26 Transformation函数join之Java实现14分钟53秒
- 4-27 Transformation函数outerJoin之Java实现23分钟16秒
- 4-28 Transformation函数cross之Scala实现28分钟07秒
- 4-29 Transformation函数cross之Java实现29分钟11秒
- 4-30 Transformation小结16分钟02秒
- 4-31 Sink函数Scala实现24分钟36秒
- 4-32 Sink函数Java实现24分钟47秒
- 4-33 通过案例引入Flink的计数器21分钟13秒
- 4-34 基于Flink编程的计时器之Scala实现26分钟44秒
- 4-35 基于Flink编程的计时器之Java实现26分钟21秒
- 4-36 基于Flink的分布式缓存功能的Scala实现25分钟57秒
- 4-37 基于Flink的分布式缓存功能的Java实现26分钟27秒
- 4-38 本章节小结及作业29分钟10秒
第5章 DataStream API编程
- 5-1 DataStream API编程概述19分钟27秒
- 5-2 从Socket创建DataStream之Java实现10分钟32秒
- 5-3 从Socket创建DataStream之Scala实现14分钟31秒
- 5-4 自定义数据源方式SourceFunction之Scala实现16分钟29秒
- 5-5 自定义数据源方式ParallelSourceFunction之Scala实现24分钟41秒
- 5-6 自定义数据源方式RichParallelSourceFunction之Scala实现26分钟54秒
- 5-7 自定义数据源方式之Java实现12分钟48秒
- 5-8 Transformation函数map和filter之Scala实现22分钟29秒
- 5-9 Transformation函数map和filter之Java实现25分钟13秒
- 5-10 Transformation函数union之Scala和Java实现19分钟55秒
- 5-11 Transformation函数split和select之Scala实现10分钟47秒
- 5-12 Transformation函数split和select之Java实现27分钟03秒
- 5-13 自定义Sink之需求描述及表创建20分钟28秒
- 5-14 自定义Sink之功能测试29分钟58秒
- 5-15 DataStream API开发小结10分钟30秒
第6章 Flink Table API & SQL编程
- 6-1 课程目录28分钟35秒
- 6-2 什么是Flink关系型API15分钟56秒
- 6-3 Table API&SQL概述25分钟
- 6-4 使用Scala完成Table API&SQL功能的开发21分钟47秒
- 6-5 使用Java完成Table API&SQL功能的开发14分钟04秒
- 6-6 Table API&SQL其他功能介绍23分钟14秒
第7章 Flink中的Time及Windows的使用
- 7-1 课程目录25分钟24秒
- 7-2 Processing Time详解11分钟05秒
- 7-3 Event Time详解22分钟28秒
- 7-4 Ingestion Time详解28分钟09秒
- 7-5 如何在Flink中指定Time的类型18分钟27秒
- 7-6 Windows概述15分钟09秒
- 7-7 Window Assigners详解13分钟13秒
- 7-8 基于Time和Count的Windows14分钟39秒
- 7-9 Tumbling Windows详解及Scala编程11分钟39秒
- 7-10 Tumbling Windows Java编程17分钟26秒
- 7-11 Sliding Windows详解及Scala编程25分钟23秒
- 7-12 Window Functions之ReduceFunction的Scala实现15分钟08秒
- 7-13 Window Functions之ReduceFunction的Java实现26分钟11秒
- 7-14 Window Functions之ProcessWindowFunction的Java实现10分钟05秒
- 7-15 作业--Window Functions之ProcessWindowFunction的Scala实现20分钟32秒
- 7-16 Flink watermark概述24分钟
第8章 Flink Connectors
- 8-1 课程目录29分钟56秒
- 8-2 Connectors概述19分钟03秒
- 8-3 HDFS Connector的使用13分钟32秒
- 8-4 Kafka Connector概述19分钟16秒
- 8-5 OOTB环境的使用29分钟56秒
- 8-6 ZooKeeper部署21分钟55秒
- 8-7 Kafka部署及测试14分钟12秒
- 8-8 Flink对接Kafka作为Source使用25分钟07秒
- 8-9 Flink对接Kafka作为Sink使用21分钟25秒
- 8-10 作业29分钟54秒
- 8-11 Flink整合Kafka的offset管理及EXACTLY_ONCE语义18分钟16秒
- 8-12 Flink整合Kafka的checkpoint常用参数设置梳理26分钟51秒
第9章 Flink部署及作业提交
- 9-1 课程目录27分钟09秒
- 9-2 Flink部署准备及源码编译23分钟25秒
- 9-3 单机模式部署及代码提交测试24分钟15秒
- 9-4 Flink Standalone模式部署及参数详解20分钟24秒
- 9-5 Hadoop集群快速搭建28分钟30秒
- 9-6 Flink on YARN两种方式18分钟20秒
- 9-7 Flink on YARN第一种模式实操12分钟42秒
- 9-8 Flink on YARN第二种模式实操11分钟07秒
- 9-9 Flink on YARN作业10分钟01秒
- 9-10 如何查找需要配置的Flink参数及UI对应关系介绍28分钟16秒
- 9-11 Flink Scala Shell的使用23分钟23秒
- 9-12 本章作业18分钟53秒
第10章 Flink监控及调优
- 10-1 课程目录11分钟29秒
- 10-2 HistoryServer概述及配置21分钟53秒
- 10-3 HistoryServer的使用14分钟32秒
- 10-4 HistoryServer REST API使用21分钟14秒
- 10-5 Monitoring REST API27分钟19秒
- 10-6 Flink Metrics15分钟36秒
- 10-7 Flink常用优化策略17分钟40秒
第11章 基于Flink的互联网直播平台日志分析项目实战
- 11-1 课程目录25分钟46秒
- 11-2 项目背景10分钟48秒
- 11-3 项目功能需求描述13分钟42秒
- 11-4 项目架构14分钟32秒
- 11-5 Mock数据之Kafka生产者代码主流程开发14分钟17秒
- 11-6 Mock数据之Kafka生产者代码日志生产开发11分钟11秒
- 11-7 使用Flink消费Kafka生产的数据17分钟11秒
- 11-8 使用Flink完成实时日志清洗功能开发13分钟22秒
- 11-9 数据清洗过程中添加业务逻辑条件的过滤26分钟38秒
- 11-10 Flink中Watermark的定义及使用15分钟17秒
- 11-11 WindowFunction业务逻辑的实现18分钟13秒
- 11-12 ES部署14分钟27秒
- 11-13 Kibana部署10分钟52秒
- 11-14 统计分析数据写入ES并通过Kibana展示出来29分钟59秒
- 11-15 通过Kibana图形化展示ES中存储的结果20分钟58秒
- 11-16 第一个功能作业15分钟36秒
- 11-17 功能二需求及数据准备14分钟02秒
- 11-18 自定义MySQL数据源读取22分钟11秒
- 11-19 完成两个流关联的数据清洗功能11分钟59秒
- 11-20 本章节总结19分钟39秒
第12章 Flink版本升级
- 12-1 课程目录19分钟08秒
- 12-2 Flink版本升级概述22分钟33秒
- 12-3 Flink部署包升级及工程依赖的Flink版本升级17分钟43秒
- 12-4 将升级后的代码运行到升级后的Flink上去19分钟42秒
第13章 (讨论群内直播内容分享)Flink读取HBase
- 13-1 本章节概述27分钟44秒
- 13-2 HBase部署22分钟03秒
- 13-3 Flink读写操作API24分钟41秒
- 13-4 Flink读写HBase依赖讲解27分钟53秒
- 13-5 Flink写数据到HBase准备工作19分钟25秒
- 13-6 Flink写数据到HBase功能开发28分钟25秒
- 13-7 Flink写数据到HBase功能测试及小问题修复28分钟09秒
- 13-8 Flink读取HBase功能开发17分钟35秒
- 13-9 正确的学习姿势分享26分钟15秒
