On 7/1/2016 6:42 AM, Akhil Das wrote:
case class Holder(str: String, js:JsValue)
Hello,
Thanks!
I tried that before posting the question to the list but I keep getting
an error such as this even after the map() operation to convert
(String,JsValue) -> Holder and then toDF().
I am simply i
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 wrote:
> Hello,
>
> I have an RDD[(String,JsValue)] that I want to convert into a DataFrame
> and then run SQL o
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: u
