【发布时间】:2017-02-03 11:53:49
【问题描述】:
我只是想使用 map 创建一个 pairRDD,我的输入文件包含 3 行数字,如下所示,
12
34
36
并将它放在 val lines 中。
以下代码行,
val pairRDD=lines.map(x => (x(0).toInt,x(1).toInt))
产生
(49,50)
(51,52)
(51,54)
结果
&
val pairRDD=lines.map(x => (x(0),x(1)))
生产
(1,2)
(3,4)
(3,6)
结果。
所以,两行代码之间的唯一区别是,我在映射之前将其转换为 Int,但是,我只有输入文件中的数字未更改。
有人可以帮我理解吗?
【问题讨论】:
标签: scala apache-spark