AWS клей pyspark - преобразование одной строки из исходной таблицы в несколько строк в месте назначения - PullRequest
1 голос
/ 02 марта 2020

У меня есть следующее требование

enter image description here

Как этого добиться с помощью функции разнесения pyspark

1 Ответ

0 голосов
/ 18 марта 2020

@ Мохаммад Муртаза Хашми. Вам снова нужна помощь.

F.split(F.concat_ws(',',*(x for x in df.columns if x.startswith('daily_qty'))),',')

Я не понимаю, как изменить вышеперечисленное, чтобы удовлетворить приведенное ниже требование.

enter image description here

В настоящее время таблица назначения выглядит следующим образом, что неверно enter image description here

...