了解Flink是什么,Flink应用程序运行的多样化,对比业界常用的流处理框架,Flink的发展趋势,Flink生态圈,Flink应用场景及Flink如何进行高效的Flink学习。
动手搭建Flink的开发环境,快速使用Java和Scala语言开发第一个基于Flink的批处理和流式处理的应用程序。
掌握Flink的核心概念及编程模型,如何在编程中执行key及转换函数,Flink支持的数据类型。
掌握Flink批处理开发的DataSet API的编程,包括数据源、转换函数、Sink、计数器以及分布式缓存的编程。
掌握Flink流处理开发的DataStream API的编程,包括数据源、转换函数、Sink的用法,以及如何自定义数据源和自定义Sink的实现。
了解Flink中统一编程模式的编程Table API以及SQL API的开发及使用。
掌握Flink中三种常用的Time处理方式,掌握Flink中滚动窗口以及滑动窗口的使用,了解Flink中的watermark。
了解Flink中常用的Connector有哪些,了解HDFS Connector的用户,掌握Flink和Kafka对接的Connnector用法。
掌握Flink的local、standalone、yarn模式的部署,如何提交Flink作业进行运行,熟悉Flink中常用的配置参数,掌握Flink cli的用法。
掌握Flink的常用监控方式以及调优策略。
掌握基于Flink的大数据项目的开发流程、处理流程及架构分析,根据需求进行功能的实现,涉及到基于Flink的实时数据清洗、业务统计、可视化展示等流程。
掌握Flink应用程序的版本升级,Flink环境的升级。
Flink作为业界最火热的计算引擎,HBase作为业界最流行的NoSQL数据库,本次课将讲解如何使用Flink高效的对HBase数据库进行数据的存取。
在本章中,将带领大家学习Flink中Table API&SQL的核心概念,DataStream/DataSet整合Table API&SQL进行开发,掌握流式SQL处理中的动态表和持续处理,并完成到1.9版本的升级。
本章中,将带领大家分析社区最新发布的Flink1.10版本中包含的新特性、改进点,让小伙伴们知晓新版本中所包含的内容,并将我们的项目升级到最新版本,结合代码对比新老版本的API所发生的变化。
本章中,会带领大家学习在Flink流处理中为什么要引入State?State分类有哪些?如何自定义实现State功能?Flink中的Checkpoint机制有什么作用?重启策略以及StateBackend在生产上如何使用?
欢迎光临 优百课栈 (https://www.ubkz.com/) | Powered by Discuz! X3.4 |