spark streaming實時流式處理wordcount,數據寫出到redis

 Spark Streaming是spark的一個組件,能夠對實時流式數據進行數據處理,數據的基本操做對象是DStream.DStream是一系列的RDDs。這個對象將流式的數據按時間切分爲一系列的rdd的數據文件。而後就對數據進行處理。rdd=DStrema At Batch Time。java   思想:建立對象ssc,實時讀取文件,處理,輸出結果寫出到redis(創建鏈接redis)mysq
相關文章
相關標籤/搜索