getOrCreate (SparkSession.Builder)

Récupère un(e) SparkSession existant(e) ou, s’il n’en existe pas, en crée un(e) nouveau/nouvelle basé(e) sur les options définies dans ce générateur.

Cette méthode vérifie d’abord s’il existe un SparkSession global default et, le cas échéant, le renvoie. Si aucun SparkSession global **default** valide n’existe, la méthode en crée un nouveau SparkSession et l’assigne comme valeur par **default** globale. Lorsqu’un SparkSession existant est renvoyé, les options de configuration spécifiées dans ce builder lui sont appliquées. Pour créer une nouvelle session sans vérification, utilisez create.

Syntaxe

getOrCreate()

Renvoie

SparkSession

Exemples

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