Spark DStream相关操作

与 RDD 类似,DStream 也提供了自己的一系列操作方法,这些操作可以分成 3 类:普通的转换操作、窗口转换操作和输出操作。 普通的转换操作 普通的转换操作如表 1 所示 表 1 普通的转换操作 Suo 描述 map(func) 源 DStream 的每个元素通过函数 func 返回一个新的 DStream。 flatMap(func) 类似于 map 操作,不同的是,每个输入元素可以被映射出 0 或者更多的输出元素 filter(func) 在源 DStream 上选择 func 函数的返回值仅为 true 的元素,最终返回一个新的 DStre