getOrCreate (SparkSession.Builder)

Får en befintlig SparkSession eller, om det inte finns någon befintlig, skapar en ny baserat på de alternativ som är satta i denna byggare.

Denna metod kontrollerar först om det finns en giltig global default SparkSession och, om så är fallet, returnerar den den. Om ingen giltig global standard SparkSession finns, skapar metoden en ny SparkSession och tilldelar den som global standard. När en befintlig SparkSession returneras tillämpas konfigurationsalternativen som anges i denna byggare på den. För att skapa en ny session utan att kontrollera, använd create.

Syntax

getOrCreate()

Returns

SparkSession

Examples

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