課程簡介
本課程主要講解Flink的核心設(shè)計原理,實時計算,SQL計算,離線計算功能和使用場景,同時通過實戰(zhàn)案例與實際業(yè)務(wù)的場景相結(jié)合,讓學(xué)員輕松掌握Flink在實時計算領(lǐng)域的獨特魅力。
本次課程的代碼實現(xiàn)以 Scala語言為主,配套有Java語言代碼實現(xiàn),要求學(xué)員至少具備Java基礎(chǔ),講師會提供培訓(xùn)過程中用到的項目代碼(Scala實現(xiàn)和Java實現(xiàn))。
目標收益
通過實戰(zhàn)案例與實際業(yè)務(wù)的場景相結(jié)合,讓學(xué)員輕松掌握Flink在實時計算領(lǐng)域的獨特魅力。
培訓(xùn)對象
大數(shù)據(jù)開發(fā)工程師,對實時計算感興趣的人員
課程大綱
第一天上午:Flink快速理解&案例實戰(zhàn) |
Flink基本原理 Flink核心設(shè)計原理 Flink整體架構(gòu)分析 Flink API層面架構(gòu)分析 Flink使用場景分析 Flink集群部署方式分析 Flink實時計算案例實戰(zhàn) Flink離線計算案例實戰(zhàn) |
第一天下午:Flink常用功能分析 |
Flink Datastrema 常用算子分析 Flink Dataset常用算子分析 Flink中的高級功能之Broadcast Flink中的高級功能之Accumulators 和Counters Flink中的高級功能之Distributed Cache Flink中的state管理與恢復(fù)機制分析 |
第二天上午:Flink高級功能分析&案例實戰(zhàn) |
Flink中的window詳解 Flink中的Time詳細分析 Flink中的Parallel分析 Flink中的CEP功能分析 Flink中的數(shù)據(jù)亂序問題分析 Flink中的watermark機制介紹 Flink中watermark案例實戰(zhàn)【解決實時計算數(shù)據(jù)亂序問題】 |
第二天下午:Flink高級功能分析&項目實戰(zhàn) |
Flink中的SQL計算功能分析 Flink SQL計算平臺架構(gòu)分析 Flink SQL實現(xiàn)企業(yè)級數(shù)據(jù)流轉(zhuǎn)功能 項目實戰(zhàn) 項目重難點分析 項目優(yōu)化 |
第一天上午:Flink快速理解&案例實戰(zhàn) Flink基本原理 Flink核心設(shè)計原理 Flink整體架構(gòu)分析 Flink API層面架構(gòu)分析 Flink使用場景分析 Flink集群部署方式分析 Flink實時計算案例實戰(zhàn) Flink離線計算案例實戰(zhàn) |
第一天下午:Flink常用功能分析 Flink Datastrema 常用算子分析 Flink Dataset常用算子分析 Flink中的高級功能之Broadcast Flink中的高級功能之Accumulators 和Counters Flink中的高級功能之Distributed Cache Flink中的state管理與恢復(fù)機制分析 |
第二天上午:Flink高級功能分析&案例實戰(zhàn) Flink中的window詳解 Flink中的Time詳細分析 Flink中的Parallel分析 Flink中的CEP功能分析 Flink中的數(shù)據(jù)亂序問題分析 Flink中的watermark機制介紹 Flink中watermark案例實戰(zhàn)【解決實時計算數(shù)據(jù)亂序問題】 |
第二天下午:Flink高級功能分析&項目實戰(zhàn) Flink中的SQL計算功能分析 Flink SQL計算平臺架構(gòu)分析 Flink SQL實現(xiàn)企業(yè)級數(shù)據(jù)流轉(zhuǎn)功能 項目實戰(zhàn) 項目重難點分析 項目優(yōu)化 |