pyspark加入多个条件

我如何指定很多条件 当我使用pyspark时.join()

例子 ： 与蜂巢：

query= "select a.NUMCNT,b.NUMCNT as RNUMCNT ,a.POLE,b.POLE as RPOLE,a.ACTIVITE,b.ACTIVITE as RACTIVITE FROM rapexp201412 b \
    join rapexp201412 a where (a.NUMCNT=b.NUMCNT and a.ACTIVITE = b.ACTIVITE and a.POLE =b.POLE  )\

但在 PySpark 中我不知道如何制作它，因为以下原因：

df_rapexp201412.join(df_aeveh,df_rapexp2014.ACTIVITE==df_rapexp2014.ACTIVITE and df_rapexp2014.POLE==df_aeveh.POLE,'inner')

这是行不通的！！

引用spark文档：

(https://spark.apache.org/docs/1.5.2/api/python/pyspark.sql.html?highlight=dataframe%20join#pyspark.sql.DataFrame.join https://spark.apache.org/docs/1.5.2/api/python/pyspark.sql.html?highlight=dataframe%20join#pyspark.sql.DataFrame.join)

join(other, on=None, how=None) 使用另一个 DataFrame 连接 给定连接表达式。

以下在 df1 和 df2 之间执行完整外连接。

参数： other – 连接的右侧 on – 用于连接的字符串 列名、列名列表、连接表达式 (Column) 或 列列表。如果 on 是一个字符串或字符串列表，则指示 连接列的名称，该列必须存在于两侧， 这执行了内部等连接。 how – str，默认“内部”。一 内连接、外连接、左外连接、右外连接、半连接。

>>> df.join(df2, df.name == df2.name, 'outer').select(df.name, df2.height).collect()
 [Row(name=None, height=80), Row(name=u'Alice', height=None), Row(name=u'Bob', height=85)]


>>> cond = [df.name == df3.name, df.age == df3.age]
>>> df.join(df3, cond, 'outer').select(df.name, df3.age).collect()
[Row(name=u'Bob', age=5), Row(name=u'Alice', age=2)]

因此，您需要像上一个示例一样使用“条件作为列表”选项。