Enrich the RDDs first with more information and then map it to some case class , if you are using scala. You can then use play api's (play.api.libs.json.Writes/play.api.libs.json.Json) classes to convert the mapped case class to json.
Thanks Deepak On Tue, Sep 20, 2016 at 6:42 PM, sujeet jog <sujeet....@gmail.com> wrote: > Hi, > > I have a Rdd of n rows, i want to transform this to a Json RDD, and also > add some more information , any idea how to accomplish this . > > > ex : - > > i have rdd with n rows with data like below , , > > 16.9527493170273,20.1989561393151,15.7065424947394 > 17.9527493170273,21.1989561393151,15.7065424947394 > 18.9527493170273,22.1989561393151,15.7065424947394 > > > would like to add few rows highlited to the beginning of RDD like below, > is there a way to > do this and transform it to JSON, the reason being i intend to push this > as input to some application via pipeRDD for some processing, and want to > enforce a JSON structure on the input. > > *{* > *TimeSeriesID : 1234* > *NumOfInputSamples : 1008 * > *Request Type : Fcast* > 16.9527493170273,20.1989561393151,15.7065424947394 > 17.9527493170273,21.1989561393151,15.7065424947394 > 18.9527493170273,22.1989561393151,15.7065424947394 > } > > > Thanks, > Sujeet > -- Thanks Deepak www.bigdatabig.com www.keosha.net