1
私は巨大な.json
ファイルを以下のように持っています。私はそのJSONをSparkのデータフレームに変換したいと思います。jsonファイルを1行に変換する
{
"movie": {
"id": 1,
"name": "test"
}
}
私は、次のコードを実行すると、私は_corrupt_record
エラーを取得する:
{ "movie": { "id": 1, "name": "test test" } }
:
val df = sqlContext.read.json("example.json")
df.first()
最近、私は、Sparkだけのように、1行JSONファイルをサポートしていることを学びましたJSONテキストを複数の行から1行に変換できますか?
改行を空の文字列に置き換えます。 –