schema_of_variant

Şemayı bir değişkenin SQL biçiminde döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.schema_of_variant(v)

Parametreler

Parametre	Türü	Description
v	pyspark.sql.Column veya str	Değişken sütun veya sütun adı.

İade

pyspark.sql.Column: Değişken şemasını temsil eden bir dize sütunu

Örnekler

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

[Row(r='OBJECT<a: BIGINT>')]