SparkStreaming源码运行架构图解

Spark Streaming基本原理：是将流数据分红小的时间片断（几秒），以相似批处理方式来处理这部分小数据。 处理流程：框架 Spark Streaming把实时输入数据流以时间片Δt （如1秒）为单位切分红块 Spark Streaming会把每块数据做为一个RDD，并使用RDD操做处理每一小块数据 每一个块都会生成一个Spark Job处理 最终结果也返回多块 Spark Streamin

>>阅读原文<<