Hi, I'm currently working on Iterable type of RDD, which is like :
val keyValueIterableRDD[CaseClass1, Iterable[CaseClass2]] = buildRDD(...) If there is only one unique key and Iterable is big enough, would this Iterable be partitioned across all executors like followings ? (executor1) (xxx, iterator from 0 to 10,000) (executor2) (xxx, iterator from 10,001 to 20,000) (executor2) (xxx, iterator from 20,001 to 30,000) ... Thanks Jason