-
-
Notifications
You must be signed in to change notification settings - Fork 119
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Resolve: #4 + Spark RDD example #13
Conversation
nums2 = sc.parallelize([3,2,1,4,5]) | ||
evens = nums2.filter(lambda elem: elem%2==0) | ||
odds = nums2.filter(lambda elem: elem%2!=0) | ||
|
||
order = pairs.union(impairs) | ||
order.takeOrdered(5) | ||
``` | ||
``` | ||
[1, 2, 3, 4, 5] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great example and explantation!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you again for the contributions - I hope you don't mind the minor formatting edit I made.
No problem at all! I'm okay with the changes so far :) it's my pleasure to contribute and also being able to learn while contributing. |
I deleted the whole repository and cloned it again, therefore, I have no Hadoop commits saved anymore, but since they are already on the original repo, its ok. I changed this 2 Spark files again, set them up in a new branch called "spark_rdd".
Hope that everything goes neat now. I will update the repo everytime from now on to avoid having this kind of problems again.
If there is something you'd like me to change, just tell me! :3