SparkStreaming數據處理過程

簡介 SparkStreaming是流式處理框架，是Spark API的擴展，支持可擴展、高吞吐量、容錯的實時數據流處理，實時數據的來源可以是：Kafka, Flume, Twitter, ZeroMQ或者TCP sockets，並且可以使用高級功能的複雜算子來處理流數據。例如:map, reduce, join, window 。最終，處理後的數據可以存放在文件系統，數據庫等，方便實時展現。

>>阅读原文<<