Как использовать pd.json_normalize() в pySpark DF ⇐ Python
-
Гость
Как использовать pd.json_normalize() в pySpark DF
Я пытался взорваться, но не смог, может кто-нибудь сказать мне, как правильно взорваться.
df = spark.createDataFrame([строка]) df.show() +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+ |ошибка|тарифПреимущества|самые низкие тарифыПродукты|продукты| ответМетаданные| ломтики| утаг| +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+ | | [ПЕРВЫЙ]| [ПЕРВЫЙ]| [FIRST]|{priceSliceIndex...|[{economyWebSpeci...|{ticket_type -> A...| +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+
теперь, как мне разбить фрагменты таким же образом, и результат должен быть df
Я пытался взорваться, но не смог, может кто-нибудь сказать мне, как правильно взорваться.
df = spark.createDataFrame([строка]) df.show() +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+ |ошибка|тарифПреимущества|самые низкие тарифыПродукты|продукты| ответМетаданные| ломтики| утаг| +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+ | | [ПЕРВЫЙ]| [ПЕРВЫЙ]| [FIRST]|{priceSliceIndex...|[{economyWebSpeci...|{ticket_type -> A...| +-----+------------+------------------+--------+-- ------------------+--------------------+---------- ----------+
теперь, как мне разбить фрагменты таким же образом, и результат должен быть df