スパークとスカラのjsonへのRDD

Question

私はspark/scalaでJsonファイルを取って、それをrddに保存します。

val dataFile = "resources/tweet-json/hello.json" 
    lazy val rdd = SparkCommons.sqlContext.read.format("json").load(dataFile) 

rddを照会した後、Json出力ファイル（get HTTPリクエストを送信します）を再度生成します。 jsonでこのrddをどのように変換できますか？

[ 
{ 
    "label": [ 
     "fattacq_an_eser_facq", 
     "eu_tot_doc", 
     "fattacq_prot_facq", 
     "id_sogg", 
     "eu_tot_man" 
    ], 
    "values": [ 
     { 
      "label": "Prima Fattura 2016", 
      "values": [ 
       2016, 
       956.48, 
       691, 
       44633, 
       956.48 
      ] 
     }, 
     { 
      "label": "Seconda Fattura 2016", 
      "values": [ 
       2016, 
       190, 
       982, 
       38127, 
       190 
      ] 
     }, 
     { 
      "label": "Terza Fattura 2016", 
      "values": [ 
       2016, 
       140.3, 
       1088, 
       59381, 
       140.3 
      ] 
     }, 
     { 
      "label": "Quarta Fattura 2016", 
      "values": [ 
       2016, 
       488, 
       1091, 
       59382, 
       488 
      ] 
     }, 
     { 
      "label": "Quinta Fattura 2016", 
      "values": [ 
       2016, 
       11365.95, 
       1154, 
       57526, 
       11365.95 
      ] 
     }, 
     { 
      "label": "Sesta Fattura 2016", 
      "values": [ 
       2016, 
       44440.01, 
       1276, 
       5555, 
       44440.01 
      ] 
     } 
    ] 
    } 
] 

Answer 1

あなたは、単にJSON 例を書き出すための書き込み機能を使用することができます。

dfTobeSaved.write.format("json").save("/root/data.json") 

私はこれが正常に動作すべきだと思います！