大數(shù)據(jù)培訓(xùn)之flink從入門到精通視頻教程【黑馬程序員】

	flink從入門到精通視頻教程
	中級(jí)	共106節(jié)課
	了解Flink，了解集群環(huán)境搭建運(yùn)維，學(xué)習(xí)Flink中重要概念、原理和API的用法，通過知識(shí)點(diǎn) + 案例教學(xué)法幫助小白快速掌握Flink。提取碼：zdsz
	下載完整視頻（已有6871人下載）

課程亮點(diǎn)：

1.知識(shí)體系完備，從小白到大神各階段讀者均能學(xué)有所獲。

2.生動(dòng)形象，化繁為簡(jiǎn)，講解通俗易懂。

3.結(jié)合工作實(shí)踐及分析應(yīng)用，培養(yǎng)解決實(shí)際問題的能力。

4.每一塊知識(shí)點(diǎn), 都有配套案例, 學(xué)習(xí)不再迷茫。

課程內(nèi)容：

1.Flink框架簡(jiǎn)介

2.Flink集群搭建運(yùn)維

3.Flink Dataset開發(fā)

4.Flink 廣播變量，分布式緩存，累加器

5.Flink Datastream開發(fā)

6.Flink Window操作

7.Flink watermark與側(cè)道輸出

8.Flink狀態(tài)計(jì)算

9.Flink容錯(cuò)checkpoint與一致性語義

10.Flink進(jìn)階 異步IO，背壓，內(nèi)存管理

11.Flink Table API與SQL

適用人群：

1.對(duì)實(shí)時(shí)計(jì)算領(lǐng)域或者Flink感興趣的在校生及應(yīng)屆畢業(yè)生。

2.對(duì)目前職業(yè)有進(jìn)一步提升要求，希望從事大數(shù)據(jù)行業(yè)高薪工作的在職人員。

3.對(duì)大數(shù)據(jù)行業(yè)感興趣的相關(guān)人員。
推薦了解黑馬成員大數(shù)據(jù)培訓(xùn)課程。

課程目錄介紹

第一章 Flink簡(jiǎn)介

01.Flink的引入

02.什么是Flink

03.Flink流處理特性

04.Flink基石

05.批處理與流處理

第二章 Flink架構(gòu)體系

01.Flink中重要角色

02.無界數(shù)據(jù)流與有界數(shù)據(jù)流

03.Flink數(shù)據(jù)流編程模型

04.Libraries支持

第三章 Flink集群搭建

01.環(huán)境準(zhǔn)備工作

02.local模式

03.Standalone集群模式

04.Standalone-HA集群模式

05.Flink On Yarn模式-介紹

06.Flink On Yarn模式-準(zhǔn)備工作

07.Flink On Yarn模式-提交方式-Session會(huì)話模式

08.Flink On Yarn模式-提交方式-Job分離模式

09. Flink運(yùn)行架構(gòu)-Flink程序結(jié)構(gòu)

10. Flink運(yùn)行架構(gòu)-Flink并行數(shù)據(jù)流

11. Flink運(yùn)行架構(gòu)-Task和Operator chain

12. Flink運(yùn)行架構(gòu)-任務(wù)調(diào)度與執(zhí)行

13. Flink運(yùn)行架構(gòu)-任務(wù)槽與槽共享

第四章 Dataset開發(fā)

01.入門案例

02.入門案例-構(gòu)建工程、log4j.properties

03.入門案例-代碼運(yùn)行yarn模式運(yùn)行

04.DataSource-基于集合

05.DataSource-基于文件

06.Transformation開發(fā)

07.Datasink-基于集合

08.Datasink-基于文件

09.執(zhí)行模式-本地執(zhí)行

10.執(zhí)行模式-集群執(zhí)行

11.廣播變量

12.累加器

13.分布式緩存

14.擴(kuò)展并行度的設(shè)置

第五章 DataStream開發(fā)

01.入門案例-流處理流程

02.入門案例-示例、參考代碼

03.流處理常見Datasource

04.Datasource基于集合

05.Datasource基于文件

06.Datasource基于網(wǎng)絡(luò)套接字

07.Datasource-自定義source-SourceFunction

08.Datasource-自定義source-ParallelSourceFunction

09.Datasource-自定義source-RichParallelSourceFunction

10.Datasource-自定義source-MysqlSource

11.Datasource-自定義source-KafkaSource

12.DataStream-transformations

13.DataSink-輸出數(shù)據(jù)到本地文件

14.DataSink-輸出數(shù)據(jù)到本地集合

15.DataSink-輸出數(shù)據(jù)到HDFS

16.DataSink-輸出數(shù)據(jù)到mysql,kafka,Redis

第六章 Flink中Window

01.為什么需要window

02.什么是window

03.Flink支持的窗口劃分方式

04.Time-window之tumbling-time-window

05.Time-window之sliding-time-window

06.Time-window之session-window

07.Count-window之tumbling-count-window

08.Count-window之sliding-count-window

09.window-Apply函數(shù)

第七章 Eventime-watermark

01.時(shí)間分類

02.watermark之?dāng)?shù)據(jù)延遲產(chǎn)生

03.watermark之解決數(shù)據(jù)延遲到達(dá)

04.watermark綜合案例

05.watermark之?dāng)?shù)據(jù)丟失

06.watermark+側(cè)道輸出保證數(shù)據(jù)不丟失

第八章 Flink狀態(tài)管理

01.狀態(tài)管理概述之無狀態(tài)計(jì)算

02.狀態(tài)管理概述之有狀態(tài)計(jì)算

03.狀態(tài)管理概述之有狀態(tài)計(jì)算場(chǎng)景

04.狀態(tài)的類型之Managed State&Raw State

05.狀態(tài)的類型之Keyed State&Operator State

06.API演示之ValueState

07.API演示之MapState

08.案例之OperatorState

09.案例之BroadcastState

第九章 Flink容錯(cuò)&重啟策略

01.checkpoint是什么

02.checkpoint執(zhí)行流程

03.checkpoint持久化存儲(chǔ)

04.案例之checkpoint設(shè)置演示

05.Flink重啟策略之重啟策略配置

06.案例之重啟策略演示

07.Savepoint與checkpoint區(qū)別

08.案例之savepoint演示

09.端到端一致性語義解釋

10.案例之kafka實(shí)現(xiàn)EndToEnd一致性語義

11.案例之Mysql實(shí)現(xiàn)EndToEnd一致性語義

第十章 Flink擴(kuò)展_異步IO_反壓_內(nèi)存管理

01.異步IO之使用前提

02.異步IO之核心API Async IO

03.案例之異步IO案例

04.什么是反壓?jiǎn)栴}

05.Flink如何解決反壓?jiǎn)栴}

06.Flink內(nèi)存管理

07.定制化內(nèi)存管理

08.定制化序列化框架

09.使用堆外內(nèi)存

第十一章 Flink-sql開發(fā)

01.Flink sql背景

02.sql常用算子之select

03.sql常用算子之where

04.sql常用算子之distinct

05.sql常用算子之group by

06.sql常用算子之union_union all

07.sql常用算子之join

08.sql常用算子之group window

09.案例之批處理sql案例

10.案例之流處理sql案例

猜你喜歡

什么是數(shù)據(jù)挖掘?數(shù)據(jù)挖掘前景怎么樣?