你好,
開始SparkSession以外的一個筆記本,你可以按照以下步驟代碼分割成小的Python模塊,利用引發功能:
在您的Python模塊,導入必要的庫火花:
從pyspark。sql進口SparkSession
初始化SparkSession開始您的模塊:
火花= SparkSession。構建器\ .appName (YourAppName) \ config (“spark.some.config。選項”、“config-value”) \ .getOrCreate ()
根據需要定製配置選項。