У меня есть такой текстовый файл:
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)