[Spark]Spark Streaming 指南三 DStreams

离散流或者DStreams是Spark Streaming提供的基本抽象，它代表一个连续的数据流。从源中获取输入流，或者是输入流通过转换算子生成的处理后的数据流。在内部，DStreams由一系列连续的 RDD组成。这是Spark对不可变，分布式数据集的抽象（更多细节参见Spark编程指南）。 DStream中的每个RDD包含来自特定间隔的数据，如下图所示： 对DStream应用的任何操作都会转换为

>>阅读原文<<