Guest User

Untitled

a guest
May 29th, 2016
54
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.42 KB | None | 0 0
  1. scala> val array = Array("age","astro")
  2. array: Array[String] = Array(age, astro)
  3.  
  4. scala> val baseRdd = sc.parallelize(array)
  5. baseRdd: org.apache.spark.rdd.RDD[String] = ParallelCollectionRDD[0] at parallelize at <console>:29
  6.  
  7. scala> val flat2 = baseRdd2.flatMap(x => x.contains("a"))
  8. <console>:31: error: type mismatch;
  9. found : Boolean
  10. required: TraversableOnce[?]
  11. val flat2 = baseRdd2.flatMap(x => x.contains("a"))
Add Comment
Please, Sign In to add comment