Something like this? import sqlContext.implicits._ case class Holder(str: String, js:JsValue)
yourRDD.map(x => Holder(x._1, x._2)).toDF() On Fri, Jul 1, 2016 at 3:36 AM, Dood@ODDO <oddodao...@gmail.com> wrote: > Hello, > > I have an RDD[(String,JsValue)] that I want to convert into a DataFrame > and then run SQL on. What is the easiest way to get the JSON (in form of > JsValue) "understood" by the process? > > Thanks! > > --------------------------------------------------------------------- > To unsubscribe e-mail: user-unsubscr...@spark.apache.org > > -- Cheers!
