DStream之转换操做（Transformation）

与 RDDs 相似，转换容许修改输入 DStream 中的数据。DStreams 支持许多在普通 Spark RDD 上可用的转换算子。一些常见的转换操做定义以下：java map(func) 经过函数 func 传递源 DStream 的每一个元素来返回一个新的DStream。web flatMap(func) 与 map 相似，可是每一个输入项能够映射到 0 或多个输出项。数据库 filter

>>阅读原文<<