SparkStreaming(源碼閱讀十二)

  要完整去學習spark源碼是一件非常不容易的事情,但是咱可以積少成多嘛~那麼,Spark Streaming是怎麼搞的呢?   本質上,SparkStreaming接收實時輸入數據流並將它們按批次劃分,然後交給Spark引擎處理生成按照批次劃分的結果流:      SparkStreaming提供了表示連續數據流的、高度抽象的被稱爲離散流的Dstream,可以使用kafka、Flume和Kin
相關文章
相關標籤/搜索