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