Взрыв массива JSON в Spark - PullRequest
0 голосов
/ 14 ноября 2018

У меня есть документ JSON, в котором есть такая запись:

{  
   "data":[  
      [  
         1,
         "CD07C40E-4943-44B0-BF5E-370DA2133E25",
         1,
         1320919663,
         "386118",
         1320919663,
         "386118",
         "{\n  \"invalidCells\" : {\n    \"1669635\" : \" \"\n  }\n}",
         null,
         " --T::00",
         null,
         null,
         null,
         [  
            null,
            null,
            null,
            null,
            null
         ],
         null
      ],
      [  
         2,
         "152ECD05-2301-43C7-88C5-085199623DA7",
         2,
         1320919663,
         "386118",
         1320919663,
         "386118",
         "{\n}",
         "6900 37th Av S",
         "Medic Response",
         1320881580,
         "47.540683",
         "-122.286131",
         [  
            null,
            "47.540683",
            "-122.286131",
            null,
            false
         ],
         "F110104166"
      ],
      [  
         3,
         "311ED596-51B7-4E70-A293-12378C61F0A6",
         3,
         1320919663,
         "386118",
         1320919663,
         "386118",
         "{\n}",
         "N 50th St / Stone Way N",
         "Aid Response",
         1320881520,
         "47.665034",
         "-122.340207",
         [  
            null,
            "47.665034",
            "-122.340207",
            null,
            false
         ],
         "F110104164"
      ]
   ]
}

У меня уже есть столбцы из предыдущей структуры в документе JSON, которые я здесь не буду помещать. Все, что мне сейчас нужно, - это получить значения из массива «data» выше и заполнить таблицу.

Я пробовал следующее, но, похоже, не работает:

import org.apache.spark.sql.functions._
seattlefire.withColumn("data", explode(seattlefire("data")).as("data_flattened")).show(false)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...