-
- Downloads
Merge pull request #276 from shivaram/collectPartition
Add collectPartition to JavaRDD interface. This interface is useful for implementing `take` from other language frontends where the data is serialized. Also remove `takePartition` from PythonRDD and use `collectPartition` in rdd.py. Thanks @concretevitamin for the original change and tests.
No related branches found
No related tags found
Showing
- core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala 11 additions, 0 deletions...rc/main/scala/org/apache/spark/api/java/JavaRDDLike.scala
- core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala 0 additions, 4 deletions...rc/main/scala/org/apache/spark/api/python/PythonRDD.scala
- core/src/test/scala/org/apache/spark/JavaAPISuite.java 33 additions, 0 deletionscore/src/test/scala/org/apache/spark/JavaAPISuite.java
- python/pyspark/context.py 0 additions, 3 deletionspython/pyspark/context.py
- python/pyspark/rdd.py 6 additions, 1 deletionpython/pyspark/rdd.py
Loading
Please register or sign in to comment