Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
10-23-2015 11:34 AM
thanks @cfregly. I think I must need a lot more remedial learning on Scala.
The reference you provided works great, but when I try to translate it into my problem via:
val dfExploded = df.explode(df("price")) { case Row(pr: Array[Row]) => pr.map(pr => Price(pr(0).asInstanceOf[String], pr(1).asInstanceOf[String]) ) }
dfExploded.show()
I wind up with exceptions.