DStream, DStreamGraph 詳解

引言 我們在前面的文章講過，Spark Streaming 的 模塊 1 DAG 靜態定義 要解決的問題就是如何把計算邏輯描述爲一個 RDD DAG 的「模板」，在後面 Job 動態生成的時候，針對每個 batch，都將根據這個「模板」生成一個 RDD DAG 的實例。 在 Spark Streaming 裏，這個 RDD 「模板」對應的具體的類是 DStream，RDD DAG 「模板」對應的具

>>阅读原文<<