apache/incubator-spark — pull request #607 by NirmalReddy (2014-02-17 13:01:43+00:00)
Title: Added Java API for AsyncRDDActions with tests

Implemented countAsync() , foreachAsync() and foreachPartitionAsync() in java API . But couldn't find a way to convert FutureAction[Seq[T]] to FutureAction[List[T]] , so collectAsync() and takeAync() are left out. If some one could please suggest a way i shall complete them .