getOrCreate (SparkSession.Builder)

既存の SparkSession を取得します。存在しない場合は、このビルダーで設定されたオプションに基づいて新しい を作成します。

このメソッドは、まず有効なグローバルdefault SparkSession が存在するかどうかを確認し、存在する場合はそれを返します。有効なグローバル default SparkSession が存在しない場合、このメソッドは新しい SparkSession を作成し、それをグローバル default として割り当てます。既存の SparkSession が返されると、このビルダーで指定された構成オプションがそれに適用されます。チェックを行わずに新しいセッションを作成するには、create を使用します。

構文

getOrCreate()

戻り値

SparkSession

例

Python

s1 = SparkSession.builder.config("k1", "v1").getOrCreate()
s1.conf.get("k1") == "v1"
# True

# The configuration of the SparkSession can be changed afterwards.
s1.conf.set("k1", "v1_new")
s1.conf.get("k1") == "v1_new"
# True

# When an existing SparkSession is returned, the config options specified
# in this builder are applied to the existing SparkSession.
s2 = SparkSession.builder.config("k2", "v2").getOrCreate()
s1.conf.get("k1") == s2.conf.get("k1") == "v1_new"
# True
s1.conf.get("k2") == s2.conf.get("k2") == "v2"
# True