Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val dates = List(Array(2019, 6, 22), Array(2019, 6, 23))
- val dates_rdd = sc.parallelize(dates)
- dates_rdd
- .map{
- case Array(year, month, day) => Seq(day).toDF
- }
- .take(2)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement