Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import util.Random.nextDouble
- var numbers = Seq.fill(1000)(nextDouble)
- val nrdd = sc.parallelize(numbers)
- val mrdd = nrdd.flatMap(a => (a)* -1.0)
- val mrdd = nrdd.map(a => -a)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement