astyle源碼詳解，Spark Streaming 源碼詳解

原地址

本系列內容適用范圍：* 2015.12.05 update, Spark 1.6 全系列 √ (1.6.0-preview，尚未正式發布)
* 2015.11.09 update, Spark 1.5 全系列 √ (1.5.0, 1.5.1, 1.5.2)
* 2015.07.15 update, Spark 1.4 全系列 √ (1.4.0, 1.4.1)
* 2015.04.17 update, Spark 1.3 全系列 √ (1.3.0, 1.3.1)

• 概述
  • 0.1 Spark Streaming 實現思路與模塊概述
• 模塊 1：DAG 靜態定義
  • 1.1 DStream, DStreamGraph 詳解
  • 1.2 DStream 生成 RDD 實例詳解
• 模塊 2：Job 動態生成
  • 2.1 JobScheduler, Job, JobSet 詳解
  • 2.2 JobGenerator 詳解
• 模塊 3：數據產生與導入
  • 3.1 Receiver 分發詳解
  • 3.2 Receiver, ReceiverSupervisor, BlockGenerator, ReceivedBlockHandler 詳解
  • 3.3 ReceiverTraker, ReceivedBlockTracker 詳解
• 模塊 4：長時容錯
  • 預計 12.13?4.1 Executor 端長時容錯詳解
  • 預計 12.13?4.2 Driver 端長時容錯詳解
• StreamingContext
  • 預計 12.20?5.1 StreamingContext 詳解