Re: Convert from RDD[Object] to RDD[Array[Object]]

2014-07-12 Thread Aaron Davidson
contains 201~210 elements. I was wondering if anybody could help me complete this scala function with an efficient way. Thanks a lot. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Convert-from-RDD-Object-to-RDD-Array-Object-tp9530.html Sent from

Re: Convert from RDD[Object] to RDD[Array[Object]]

2014-07-12 Thread Mark Hamstra
by one previously. For example, there was a RDD denoted by data: RDD[Object] and then I processed it using data.map(...). However, I got a new requirement to process the data in a patched way. It means that I need to convert the RDD from RDD[Object] to RDD[Array[Object]] and then process it, which