開始使用免費開始

建立 SparkSession

我們已經幫你建立了一個名為 sparkSparkSession。但如果你不確定是否已經存在呢?建立多個 SparkSessionSparkContext 可能會造成問題,所以最佳做法是使用 SparkSession.builder.getOrCreate()。如果環境中已經有現成的 SparkSession,它會直接回傳;若沒有,就會建立一個新的!

本練習屬於課程

PySpark 基礎

檢視課程

練習說明

  • pyspark.sql 匯入 SparkSession
  • 使用 SparkSession.builder.getOrCreate() 建立一個名為 my_spark 的新 SparkSession
  • my_spark 列印到主控台,確認它是 SparkSession

動手互動練習

試著完成這個範例程式碼,體驗一下這個練習。

# Import SparkSession from pyspark.sql
from ____ import ____

# Create my_spark
my_spark = ____

# Print my_spark
print(____)
編輯並執行程式碼