rdd.map(e=>e.split("\\s")).map(e=>(e(0),e(1))).groupByKey()
On Fri, Feb 26, 2016 at 3:20 PM, Bonsen wrote:
> I have a file,like 1.txt:
> 1 2
> 1 3
> 1 4
> 1 5
> 1 6
> 1 7
> 2 4
> 2 5
> 2 7
> 2 9
>
> I want to merge them,results like this
> map（1->List（2，3，4，5，6，7）,2->List(4,5,7,9))
> what should I do？。。
> val file1=sc.textFile("1.txt")
> val q1=file1.flatMap(_.split(' '))???，maybe I should change RDD[int] to
> RDD[int,int]?
>
>
>
> --
> View this message in context:
> http://apache-spark-user-list.1001560.n3.nabble.com/When-I-merge-some-datas-can-t-go-on-tp26341.html
> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>
> -
> To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
> For additional commands, e-mail: user-h...@spark.apache.org
>
>
--
Best Regards
Jeff Zhang
