Freigeben über


getActiveSession

Gibt den aktiven SparkSession für den aktuellen Thread zurück, der vom Generator zurückgegeben wird.

Syntax

SparkSession.getActiveSession()

Rückkehr

SparkSession oder None

Beispiele

s = SparkSession.getActiveSession()
df = s.createDataFrame([('Alice', 1)], ['name', 'age'])
df.select("age").show()
# +---+
# |age|
# +---+
# |  1|
# +---+