幫助中心 | 我的帳號 | 關於我們

Flink入門與實戰/51CTO學院叢書

  • 作者:徐葳
  • 出版社:人民郵電
  • ISBN:9787115516787
  • 出版日期:2019/10/01
  • 裝幀:平裝
  • 頁數:226
人民幣:RMB 59 元      售價:
放入購物車
加入收藏夾

內容大鋼
    本書旨在幫助讀者從零開始快速掌握Flink的基本原理與核心功能。本書首先介紹了Flink的基本原理和安裝部署,並對Flink中的一些核心API進行了詳細分析。然後配套對應的案例分析,分別使用Java代碼和Scala代碼實現案例。最後通過兩個項目演示了Flink在實際工作中的一些應用場景,幫助讀者快速掌握Flink開發。
    學習本書需要大傢具備一些大數據的基礎知識,比如Hadoop、Kafka、Redis、Elasticsearch等框架的基本安裝和使用。本書也適合對大數據實時計算感興趣的讀者閱讀。

作者介紹
徐葳
    徐葳,專註于大數據技術方向,屬於國內較早一批從事大數據的開發者,擁有10年以上互聯網公司軟體研發經驗。     曾任職于北京獵豹移動、中科院大數據技術研究院等企業。     曾為移動研究院、平安壽險、中信銀行、花旗銀行、中移在線等企業進行大數據技術培訓。

目錄
第1章  Flink概述
  1.1  Flink原理分析
  1.2  Flink架構分析
  1.3  Flink基本組件
  1.4  Flink流處理(Streaming)與批處理(Batch)
  1.5  Flink典型應用場景分析
  1.6  流式計算框架對比
  1.7  工作中如何選擇實時計算框架
第2章  Flink快速入門
  2.1  Flink開發環境分析
    2.1.1  開發工具推薦
    2.1.2  Flink程序依賴配置
  2.2  Flink程序開發步驟
  2.3  Flink流處理(Streaming)案例開發
    2.3.1  Java代碼開發
    2.3.2  Scala代碼開發
    2.3.3  執行程序
  2.4  Flink批處理(Batch)案例開發
    2.4.1  Java代碼開發
    2.4.2  Scala代碼開發
    2.4.3  執行程序
第3章  Flink的安裝和部署
  3.1  Flink本地模式
  3.2  Flink集群模式
    3.2.1  Standalone模式
    3.2.2  Flink on Yarn模式
    3.2.3  yarn-session.sh命令分析
    3.2.4  Flink run命令分析
  3.3  Flink代碼生成JAR包
  3.4  Flink HA的介紹和使用
    3.4.1  Flink HA
    3.4.2  Flink Standalone集群的HA安裝和配置
    3.4.3  Flink on Yarn集群HA的安裝和配置
  3.5  Flink Scala Shell
第4章  Flink常用API詳解
  4.1  Flink API的抽象級別分析
  4.2  Flink DataStream的常用API
    4.2.1  DataSource
    4.2.2  Transformation
    4.2.3  Sink
  4.3  Flink DataSet的常用API分析
    4.3.1  DataSource
    4.3.2  Transformation
    4.3.3  Sink
  4.4  Flink Table API和SQL的分析及使用
    4.4.1  Table API和SQL的基本使用
    4.4.2  DataStream、DataSet和Table之間的轉換
    4.4.3  Table API和SQL的案例
  4.5  Flink支持的DataType分析
  4.6  Flink序列化分析

第5章  Flink高級功能的使用
  5.1  Flink Broadcast
  5.2  Flink Accumulator
  5.3  Flink Broadcast和Accumulator的區別
  5.4  Flink Distributed Cache
第6章  Flink State管理與恢復
  6.1  State
    6.1.1  Keyed State
    6.1.2  Operator State
  6.2  State的容錯
  6.3  CheckPoint
  6.4  StateBackend
  6.5  Restart Strategy
  6.6  SavePoint
第7章  Flink窗口詳解
  7.1  Window
  7.2  Window的使用
    7.2.1  Time Window
    7.2.2  Count Window
    7.2.3  自定義Window
  7.3  Window聚合分類
    7.3.1  增量聚合
    7.3.2  全量聚合
第8章  Flink Time詳解
  8.1  Time
  8.2  Flink如何處理亂序數據
    8.2.1  Watermark
    8.2.2  Watermark的生成方式
  8.3  EventTime+Watermark解決亂序數據的案例詳解
    8.3.1  實現Watermark的相關代碼
    8.3.2  通過數據跟蹤Watermark的時間
    8.3.3  利用Watermark+Window處理亂序數據
    8.3.4  Late Element的處理方式
    8.3.5  在多並行度下的Watermark應用
    8.3.6  With Periodic Watermarks案例總結
第9章  Flink並行度詳解
  9.1  Flink並行度
  9.2  TaskManager和Slot
  9.3  並行度的設置
    9.3.1  並行度設置之Operator Level
    9.3.2  並行度設置之Execution Environment Level
    9.3.3  並行度設置之Client Level
    9.3.4  並行度設置之System Level
  9.4  並行度案例分析
第10章  Flink Kafka Connector詳解
  10.1  Kafka Connector
  10.2  Kafka Consumer
    10.2.1  Kafka Consumer消費策略設置
    10.2.2  Kafka Consumer的容錯
    10.2.3  動態載入Topic

    10.2.4  Kafka Consumer Offset自動提交
  10.3  Kafka Producer
    10.3.1  Kafka Producer的使用
    10.3.2  Kafka Producer的容錯
第11章  Flink實戰項目開發
  11.1  實時數據清洗(實時ETL)
    11.1.1  需求分析
    11.1.2  項目架構設計
    11.1.3  項目代碼實現
  11.2  實時數據報表
    11.2.1  需求分析
    11.2.2  項目架構設計
    11.2.3  項目代碼實現

  • 商品搜索:
  • | 高級搜索
首頁新手上路客服中心關於我們聯絡我們Top↑
Copyrightc 1999~2008 美商天龍國際圖書股份有限公司 臺灣分公司. All rights reserved.
營業地址:臺北市中正區重慶南路一段103號1F 105號1F-2F
讀者服務部電話:02-2381-2033 02-2381-1863 時間:週一-週五 10:00-17:00
 服務信箱:bookuu@69book.com 客戶、意見信箱:cs@69book.com
ICP證:浙B2-20060032