getOrCreate (SparkSession.Builder)

Krijgt een bestaande SparkSession of, als die er niet is, maakt hij een nieuwe aan op basis van de opties die in deze builder zijn ingesteld.

Deze methode controleert eerst of er een geldige globale default SparkSession is en, als dat zo is, geeft die terug. Als er geen geldige globale standaard SparkSession bestaat, maakt de methode een nieuwe SparkSession aan en wijst deze toe als globale standaard. Wanneer een bestaande SparkSession wordt teruggegeven, worden de configuratie-opties die in deze builder zijn gespecificeerd toegepast. Om een nieuwe sessie aan te maken zonder te controleren, gebruik 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