一、培訓(xùn)簡(jiǎn)述
Apache Flink（下簡(jiǎn)稱(chēng)Flink）項(xiàng)目是大數(shù)據(jù)處理領(lǐng)域最近冉冉升起的一顆新星，其不同于其他大數(shù)據(jù)項(xiàng)目的諸多特性吸引了越來(lái)越多人的關(guān)注。Apache Flink 是一個(gè)分布式大數(shù)據(jù)處理引擎，可對(duì)有限數(shù)據(jù)流和無(wú)限數(shù)據(jù)流進(jìn)行有狀態(tài)計(jì)算。可部署在各種集群環(huán)境，對(duì)各種大小的數(shù)據(jù)規(guī)模進(jìn)行快速計(jì)算。
本次課程將深入分析Flink的一些關(guān)鍵技術(shù)與特性，希望能夠通過(guò)課程的學(xué)習(xí)對(duì)Flink的體系架構(gòu)和生態(tài)圈組件有更加深入的了解，對(duì)其他大數(shù)據(jù)系統(tǒng)開(kāi)發(fā)者也能有所裨益。本課程結(jié)合MapReduce、Spark及Storm等大數(shù)據(jù)處理框架，同時(shí)結(jié)合業(yè)務(wù)場(chǎng)景來(lái)幫著學(xué)員熟悉大數(shù)據(jù)流處理與批處理的基本概念。
本課程主要包含以下方面內(nèi)容：

• 了解Flink大數(shù)據(jù)架構(gòu)，互聯(lián)網(wǎng)企業(yè)大數(shù)據(jù)應(yīng)用
• 深度了解Flink DataSet API
• 深度了解DataStream API
• 集成Kafka與Flink
• 熟悉Table API
• 熟悉Flink ML
• 熟悉Flink優(yōu)化與基于大數(shù)據(jù)的體系架構(gòu)

二、培訓(xùn)特色

• PPT+教材+參考資料，理論講解
• 提供配套的實(shí)驗(yàn)環(huán)境
• 場(chǎng)景+案例+模擬環(huán)境，動(dòng)手實(shí)踐
• 手把手解決問(wèn)題+解決問(wèn)題經(jīng)驗(yàn)分享

三、培訓(xùn)收益

• 掌握基于Flink的大數(shù)據(jù)的體系架構(gòu)、管理、部署。
• 讓學(xué)員具備部署基于Flink的企業(yè)大數(shù)據(jù)平臺(tái)環(huán)境的能力。

四、培訓(xùn)時(shí)長(zhǎng)
共計(jì) 3天，每天6課時(shí)

五、培訓(xùn)大綱

第一天：Flink基礎(chǔ)
章	節(jié)	練習(xí)	學(xué)習(xí)目標(biāo)
第1章：Scala編程語(yǔ)言	Scala語(yǔ)言基礎(chǔ) Scala語(yǔ)言的面向?qū)ο?/li> Scala語(yǔ)言的函數(shù)式編程 Scala中的集合 Scala語(yǔ)言的高級(jí)特性	編程Scala程序	掌握Scala編程語(yǔ)言
第2章：常見(jiàn)的大數(shù)據(jù)計(jì)算引擎及其架構(gòu)	大數(shù)據(jù)離線計(jì)算引擎 MapReduce Spark Core Flink DataSet 大數(shù)據(jù)實(shí)時(shí)計(jì)算引擎 Storm Spark Streaming Flink DataStream		掌握不同的大數(shù)據(jù)計(jì)算引擎的架構(gòu)特點(diǎn)
第3章：Flink的體系架構(gòu)與部署	Flink簡(jiǎn)介 Flink的體系架構(gòu) Flink的安裝與部署 Flink的分布式緩存 對(duì)比：Flink、Storm和Spark Streaming	安裝與部署Flink環(huán)境	掌握Flink的體系架構(gòu)與生態(tài)圈組件
第4章：Flink on Yarn的實(shí)現(xiàn)	什么是Yarn？與Yarn的體系架構(gòu) 部署Yarn Flink on Yarn的兩種模式 內(nèi)存集中管理模式 內(nèi)存Job管理模式 Flink on Yarn兩種模式的區(qū)別	部署Flink on Yarn	理解并掌握Flink on Yarn的兩種模式的特點(diǎn)
第5章：Flink HA的實(shí)現(xiàn)	什么是HA？為什么需要HA？ 大數(shù)據(jù)分布式協(xié)調(diào)框架ZooKeeper 什么是ZooKeeper 搭建ZooKeeper環(huán)境 ZooKeeper的特性 實(shí)現(xiàn)分布式鎖 部署Flink HA高可用架構(gòu)環(huán)境	部署Flink HA環(huán)境	什么是HA？Flink HA的架構(gòu)
第6章：Flink開(kāi)發(fā)入門(mén)	Flink批處理開(kāi)發(fā) Java版本W(wǎng)ordCount Scala版本W(wǎng)ordCount Flink流處理開(kāi)發(fā) Java版本W(wǎng)ordCount Scala版本W(wǎng)ordCount 使用Flink Scala Shell Flink的并行度分析	搭建Flink開(kāi)發(fā)環(huán)境并開(kāi)發(fā)應(yīng)用程序	掌握基本的Flink API編程
第7章：集成Kafka	大數(shù)據(jù)流式計(jì)算的典型架構(gòu) Kafka的體系結(jié)構(gòu)和環(huán)境部署 Kafka核心原理解析 集成Flink與Kafka	集成Kakfa與Flink	掌握大數(shù)據(jù)實(shí)時(shí)計(jì)算的架構(gòu)與集成