7.7 DStream的转换操作
Spark Streaming中对DStream的转换操作会转变成对RDD的转换操转换流程如下。
其中,lines表示转换操作前的DStream,words表示转换操作后生成的DStream。对lines做flatMap转换操作,也就是对它内部的所有RDD做flatMap转换操作。
最后修改: 2021年10月29日 星期五 13:06
Spark Streaming中对DStream的转换操作会转变成对RDD的转换操转换流程如下。
其中,lines表示转换操作前的DStream,words表示转换操作后生成的DStream。对lines做flatMap转换操作,也就是对它内部的所有RDD做flatMap转换操作。