如何使用PySpark运行多行sql查询？

Question

spark.sql("Select acts.accountname, acts.county_state,loc.Town, acts.country from assure_crm_accounts acts inner join assure_crm_accountlocation loc on acts.GPAddressCode = loc.GPAddressCode").show(30, False)

当我使用PySpark使用多行查询时遇到错误，有没有一种方法可以使用单个命令运行多行查询

Answer 1

您还可以使用三重引号编写多行字符串sql查询，如下所示：

spark.sql("""
Select acts.accountname, acts.county_state,loc.Town, acts.country 
from assure_crm_accounts acts 
inner join assure_crm_accountlocation loc 
on acts.GPAddressCode = loc.GPAddressCode
"""
)

Answer 2

只需在每行末尾加上“\”：

spark.sql("Select acts.accountname, acts.county_state,loc.Town, acts.country from \
assure_crm_accounts acts inner join assure_crm_accountlocation loc on \
acts.GPAddressCode = loc.GPAddressCode").show(30, False)