Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Il en obtient un existant SparkSession ou, s’il n’y en a pas, en crée un nouveau en fonction des options proposées dans ce constructeur.
Cette méthode vérifie d’abord s’il existe un défaut SparkSession global valide et, le cas échéant, le retourne. S’il n’existe pas de défaut SparkSession global valide, la méthode en crée un nouveau SparkSession et l’assigne comme par défaut global. Lorsqu’un existant SparkSession est retourné, les options de configuration spécifiées dans ce constructeur lui sont appliquées. Pour créer une nouvelle session sans vérifier, utilisez 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