一個用來表示 Python 變體值的類別。
語法
from pyspark.sql.types import VariantVal
VariantVal(value, metadata)
參數
| 參數 |
類型 |
說明 |
value |
bytes |
代表變體值成分的位元組。 |
metadata |
bytes |
代表變體中元資料部分的位元組。 |
方法
| 方法 |
說明 |
toPython() |
將 VariantVal 轉換成 Python 資料結構。 |
toJson() |
將 VariantVal 轉換成 JSON 字串。 區域ID代表該時間戳記應該印製的時區。 預設為 UTC。 有效區域 ID 清單可透過匯入 zoneinfo 模組並執行 zoneinfo.available_timezones()來找到。 |
parseJson() |
將 VariantVal 轉換成巢狀的 Python 物件，包含 Python 資料型別。 |
Examples
from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }'''} ])
v = df.select(sf.parse_json(df.json).alias("var")).head().var
v.toPython()
# {'a': 1}
v.toJson()
# '{"a":1}'