spark streaming 5: InputDStream

spark streaming 5: InputDStream InputDStream的繼承關係。他們都是使用 InputDStream這個抽象類的接口進行操作的。特別注意 ReceiverInputDStream這個類，大部分時候我們使用的是它作爲擴展的基類，因爲它才能（更容易）使接收數據的工作分散到各個worker上執行，更符合分佈式計算的理念。 所有的輸入流都某個時間間隔將數據以block

>>阅读原文<<