PySpark：如何将数据帧与存储在其他变量中的列名连接起来

Question

我正在尝试学习 PySpark。我必须根据相应的列 和来左连接两个数据框，比如说A和。通常，我会这样做：Bcolname_acolname_b

# create a new dataframe AB:
AB = A.join(B, A.colname_a == B.colname_b, how = 'left')

但是，我无法直接获得列的名称。它们已存储在特定的模块中，我必须这样调用它们：

module.COLNAME_A   # contains string with colname of A
module.COLNAME_B   # contains string with colname of B

如何将这些字符串值放入上面的命令中，以便加入数据帧？

Answer 1

使用方括号而不是点符号来访问列名称：

AB = A.join(B, A[module.COLNAME_A] == B[module.COLNAME_B], how = 'left')