spark-join-2Dataframe

c90pui9n  于 2021-05-29  发布在  Spark
关注(0)|答案(1)|浏览(317)

我有两个Dataframedf1和df2。我在Map中定义了这些Dataframe的连接条件。但是联接列名不同。
我知道我可以这样做,
val df3 = df2.join(df1, df2("col1") <=> df1("col5") && df2("col2") <=> df1("col6") && df2("col3") <=> df1("col7") && df2("col4") <=> df1("col8"), "left" ) 有没有一种方法可以使用map中的值动态创建连接条件。

zxlwwiss

zxlwwiss1#

你可以用

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

如果您以前从df2重命名列,因为列必须在两侧都存在。

相关问题