バリアントのスキーマ

バリアントの SQL 形式でスキーマを返します。

構文

Python

from pyspark.sql import functions as sf

sf.schema_of_variant(v)

パラメーター

パラメーター	Type	説明
v	pyspark.sql.Column または文字列	バリアント列または列名。

戻り値

pyspark.sql.Column: バリアントスキーマを表す文字列列

例

Python

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()

Output

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