Skip to content

GitLab

Explore

Sign in

Primary navigation

Project

S

spark
- Activity
- Members
- Labels
- Issues
- Issue boards
- Milestones
- Wiki
- Releases
- Model registry
- Environments
- Incidents

Snippets Groups Projects

af0cd6bd

Commit af0cd6bd authored 11 years ago by Shivaram Venkataraman

Downloads
- Patches
- Plain Diff

Add collectPartition to JavaRDD interface.

Also remove takePartition from PythonRDD and use collectPartition in rdd.py.

parent 7a8169be

No related branches found

No related tags found

No related merge requests found

Changes 5

Hide whitespace changes

Inline Side-by-side

Showing

core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala 10 additions, 1 deletion

...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 28 additions, 0 deletions

core/src/test/scala/org/apache/spark/JavaAPISuite.java
python/pyspark/context.py 0 additions, 3 deletions

python/pyspark/context.py
python/pyspark/rdd.py 1 addition, 1 deletion

python/pyspark/rdd.py

with 39 additions and 9 deletions

Loading

0% Loading or .

You are about to add 0 people to the discussion. Proceed with caution.

Finish editing this message first!

Please register or sign in to comment