pyspark dataframe join 动态传入条件

例如：df=df1.join(df2,[df1.a==df2.a,df1.b==df2.b],"outer")
其中的关联条件想要动态传入
因为想写一个通用的程序，每个表的关联条件不一样

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 关于该问题，我找了一篇非常好的博客，你可以看看是否有帮助，链接：PySpark系列：df.join的使用

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 以帮助更多的人 ^-^