用於建立會話設定的介面。
Syntax
builder
Methods
| 方法 | 說明 |
|---|---|
appName(name) |
為應用程式設定名稱，名稱會在 Spark 網頁介面中顯示。 |
create() |
建立一個新的 SparkSession。 |
config(key, value, conf, map) |
設定一個設定選項。 選項會自動傳播到 SparkConf 和 SparkSession 自己的設定。 |
enableHiveSupport() |
啟用 Hive 支援，包括連接持續存在的 Hive 元儲存庫。 |
getOrCreate() |
取得現有的 SparkSession，或如果沒有現有的，則根據這個建構器設定的選項建立一個新的。 |
master(master) |
設定 Spark 主 URL 要連接。 |
remote(url) |
將 Spark 遠端 URL 設定為透過 Spark Connect 連接。 |
Examples
spark = (
SparkSession.builder
.master("local")
.appName("Word Count")
.config("spark.some.config.option", "some-value")
.getOrCreate()
)
spark.sql("SELECT * FROM range(10) where id > 7").show()
+---+
| id|
+---+
| 8|
| 9|
+---+
spark.createDataFrame([('Alice', 1)], ['name', 'age']).show()
+-----+---+
| name|age|
+-----+---+
|Alice| 1|
+-----+---+
spark.range(1, 7, 2).show()
+---+
| id|
+---+
| 1|
| 3|
| 5|
+---+