getOrCreate (SparkSession.Builder)

Er bekommt einen bestehenden SparkSession oder, falls es keinen gibt, erstellt er einen neuen basierend auf den in diesem Builder festgelegten Optionen.

Diese Methode prüft zunächst, ob es einen gültigen globalen Standard SparkSession gibt, und gibt diesen gegebenenfalls zurück. Wenn kein gültiger globaler Standard SparkSession existiert, erstellt die Methode einen neuen SparkSession und weist ihn als globalen Standard zu. Wenn ein existierendes SparkSession Gerät zurückgegeben wird, werden die in diesem Builder angegebenen Konfigurationsoptionen darauf angewendet. Um eine neue Sitzung ohne Überprüfung zu erstellen, verwenden createSie .

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