One approach would be to use SaveAsNewAPIHadoop file and specify
jsonOutputFormat.
Another simple one would be like:
val rdd = sc.parallelize(1 to 100)
val json = rdd.map(x => {
val m: Map[String, Int] = Map("id" -> x)
new JSONObject(m) })
json.saveAsTextFile("output")
Thanks
Best Regards
On Tue, Nov 11, 2014 at 6:28 PM, Naveen Kumar Pokala <
[email protected]> wrote:
> Hi,
>
>
>
> I am spark 1.1.0. I need a help regarding saving rdd in a JSON file?
>
>
>
> How to do that? And how to mentions hdfs path in the program.
>
>
>
>
>
> -Naveen
>
>
>
>
>
