7.7 DStream的转换操作

Spark Streaming中对DStream的转换操作会转变成对RDD的转换操转换流程如下。

其中,lines表示转换操作前的DStream,words表示转换操作后生成的DStream。对lines做flatMap转换操作,也就是对它内部的所有RDD做flatMap转换操作。

Last modified: Friday, 29 October 2021, 1:06 PM