getOrCreate (SparkSession.Builder)

Otrzymuje istniejący SparkSession lub jeśli nie ma żadnego istniejącego, tworzy nowy na podstawie opcji ustawionych w tym builderze.

Ta metoda najpierw sprawdza, czy istnieje prawidłowy globalny domyślny SparkSession sygnał i jeśli tak, zwraca go. Jeśli nie istnieje żadna ważna globalna domyślność SparkSession , metoda tworzy nową SparkSession i przypisuje ją jako globalną domyślną. Gdy zwrócone zostanie istniejące, SparkSession stosuje się do niego opcje konfiguracyjne określone w tym kreatorze. Aby utworzyć nową sesję bez sprawdzania, użyj 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