Фрейм данных Spark join 2 на основе нескольких столбцов - PullRequest
1 голос
/ 18 июня 2020

У меня есть 2 фрейма данных df1 и df2. У меня есть условие соединения для этих фреймов данных, определенных на карте. Однако имена столбцов соединения различаются.

Я знаю, что могу сделать вот так: способ динамического создания условия соединения с использованием значений в карте.

1 Ответ

2 голосов
/ 19 июня 2020

Вы можете использовать

val df3 = df2.join(df1, Seq("col5", "col6", "col7", "col8"), "left")

, если вы ранее переименовали столбцы из df2, потому что столбцы должны существовать с обеих сторон.

...