SparkStreaming介紹以及演示示例程序

簡介:SparkStreaming是spark的一個模塊,進行實時流數據的處理,如何處理呢,就是把數據流沿用一系列的批次數據,然後用DStream的抽象封裝 那麼DStream是什麼呢?RDD + 時間 = 有一個抽象的DStream,代表一個連續的數據流 我們都知道,spark的抽象是RDD,用SparkContext抽象進行封裝,sparkSQL的抽象是DataSet/DataFrame,用S
相關文章
相關標籤/搜索