0

我有一个这样的文本文件:

1,abc
34,bvc
98,def
43,mnl
12,xyz
54,hij

val rddtemp= sc.textFile("/tmp/tabletest.txt")

val maprdd = rddtemp.map(x=> (x.split(",")(0)+ 3, x.split(",")(1) )).foreach(println)

这给了我:

(123,xyz)
(543,hij)
(13,abc)
(343,bvc)
(983,def)
(433,mnl)

使用+连接到第一列,但我想添加到第一列,给出:

(15,xyz)
(57,hij)
(4,abc)
(37,bvc)
(101,def)
(46,mnl)
4

1 回答 1

2

拆分后,您得到了 Array[String],而字符串的 + 是连接。您需要先将其转换为 Int

val maprdd = rddtemp.
             map(_.split(",")).
             map(arr => (arr(0).toInt + 3, arr(1))).
             foreach(println)
于 2014-11-07T16:29:43.370 回答