在pyspark中加載SQl查詢？

Question

有沒有什麼方法可以直接從oracle sql使用pyspark來讀取sql腳本？ 我一直在pyspark中加載兩張桌子並試圖加入，在pyspark花費很長時間，我需要加入更多桌子（6張桌子）。這在Oracle Sql中並不需要太多時間。

那麼我怎樣才能讀取和運行一個「X.sql」與pyspark文件？

Answer 1

所以我已經找到一個解決辦法：

with open("C:\Desktop\Project\Alerts.sql") as Al: 
    Alert= Al.read() 
results = sqlctx.sql(Alert)