为什么在map方法中将一个带有3字段元组的普通rdd转换成一个键值对是有效的?

dsf9zpds  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(228)

根据一个在线练习,下面的代码转换一个字符串rdd,其中每一行都被解析为一个元组,其中包含3个字段 toTuple() -一个包含两个字段的元组,或者换句话说,一个pairdd。
为什么这样做?我认为在=>之后只允许表达式。但是是的 (toTuple(x)._1, toTuple(x)._4) 一个表情?还是我的想法完全错了?

  1. val RddAsKvPair = filteredRDD.map(x => (toTuple(x)._1, toTuple(x)._4))

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题