variant_get

Estrae una variante secondaria da v in base a pathe quindi esegue il cast della variante secondaria in targetType. Restituisce Null se il percorso non esiste. Genera un'eccezione se il cast ha esito negativo.

Sintassi

from pyspark.sql import functions as sf

sf.variant_get(v, path, targetType)

Parametri

Parametro	TIPO	Description
v	pyspark.sql.Column o str	Nome di colonna o colonna variante.
path	pyspark.sql.Column o str	Colonna contenente le stringhe del percorso di estrazione o una stringa che rappresenta il percorso di estrazione. Un percorso valido deve iniziare con $ ed è seguito da zero o più segmenti come [123], .name, ['name']o ["name"].
targetType	str	Tipo di dati di destinazione in cui eseguire il cast in una stringa in formato DDL.

Restituzioni

pyspark.sql.Column: colonna di targetType che rappresenta il risultato estratto

Esempi

from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }''', 'path': '$.a'} ])
v = sf.parse_json(df.json)
df.select(sf.variant_get(v, "$.a", "int").alias("r")).collect()

[Row(r=1)]

df.select(sf.variant_get(v, "$.b", "int").alias("r")).collect()

[Row(r=None)]

df.select(sf.variant_get(sf.parse_json(df.json), df.path, "int").alias("r")).collect()

[Row(r=1)]