Guest User

Untitled

a guest
Oct 17th, 2017
65
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.91 KB | None | 0 0
  1. scala> var ek: RDD[Set[Int]] = sc.parallelize(Seq(Set(7)))
  2. ek: org.apache.spark.rdd.RDD[Set[Int]] = ParallelCollectionRDD[31] at parallelize at <console>:32
  3.  
  4. scala> val vi: RDD[Set[Int]] = sc.parallelize(Seq(Set(3,5)))
  5. vi: org.apache.spark.rdd.RDD[Set[Int]] = ParallelCollectionRDD[32] at parallelize at <console>:32
  6.  
  7. scala> val z = vi.union(ek)
  8. z: org.apache.spark.rdd.RDD[Set[Int]] = UnionRDD[34] at union at <console>:36
  9.  
  10. scala> z.collect
  11. res15: Array[Set[Int]] = Array(Set(3, 5), Set(7))
  12.  
  13. scala> val t = visited++ek
  14. t: org.apache.spark.rdd.RDD[Set[Int]] = UnionRDD[40] at $plus$plus at <console>:36
  15.  
  16. scala> t.collect
  17. res30: Array[Set[Int]] = Array(Set(3, 5), Set(7))
  18.  
  19. Array(Set(3, 5), Set(7))
  20.  
  21. scala> val u = Set(3,5)
  22. u: scala.collection.immutable.Set[Int] = Set(3, 5)
  23.  
  24. scala> val o = Set(7)
  25. o: scala.collection.immutable.Set[Int] = Set(7)
  26.  
  27. scala> u.union(o)
  28. res28: scala.collection.immutable.Set[Int] = Set(3, 5, 7)
Add Comment
Please, Sign In to add comment