Advertisement
Guest User

Untitled

a guest
Jun 27th, 2019
93
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.18 KB | None | 0 0
  1. val dates = List(Array(2019, 6, 22), Array(2019, 6, 23))
  2.  
  3. val dates_rdd = sc.parallelize(dates)
  4.  
  5. dates_rdd
  6.   .map{
  7.     case Array(year, month, day) => Seq(day).toDF
  8.   }
  9.   .take(2)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement