I don't think this is provided out of the box, but you can use toSeq on your Iterable and if the Iterable is lazy, it should stay that way for the Seq. And then you can use sc.parallelize(my-iterable.toSeq) so you'll have your RDD.
For the Iterable[Iterable[T]] you can flatten it and then create your RDD from the corresponding Iterable. Regards, Olivier. 2014-10-21 5:07 GMT+02:00 Dai, Kevin <yun...@ebay.com>: > In addition, how to convert Iterable[Iterable[T]] to RDD[T] > > > > Thanks, > > Kevin. > > > > *From:* Dai, Kevin [mailto:yun...@ebay.com] > *Sent:* 2014年10月21日 10:58 > *To:* user@spark.apache.org > *Subject:* Convert Iterable to RDD > > > > Hi, All > > > > Is there any way to convert iterable to RDD? > > > > Thanks, > > Kevin. >
