磚

你好所有的,我終於應用以下方法,添加一個持續從DB: dataframe當抓取數據的數據量小,它的工作原理。def get_table_from_db(自我,table_name) - > pyspark.sql。DataFrame: df = self.spark.rea……

你好,我嚐試了所有該配置但還是同樣的問題。我們需要檢查在土塊sql級別的配置。我讓你更新的解決方案我們將found.Thks

嗨@Rama克裏希納N,我使用一個類的方法get_table_from_db遵循:類ExtractData: def __init__(自我,db:枚舉,* * kwargs):自我。db_name = db.DB_NAME。自我價值。db =自我。kwargs = kwargs self.spa……