結構

建立一個新的結構體欄位。

語法

from pyspark.sql import functions as sf

sf.struct(*cols)

參數

參數	類型	Description
cols	列表、集合或 pyspark.sql.Column 欄位名稱	欄位名稱或欄位，要包含在輸出結構中。

退貨

pyspark.sql.Column： 一個結構型別的欄位，包含給定欄位。

範例

import pyspark.sql.functions as sf
df = spark.createDataFrame([("Alice", 2), ("Bob", 5)], ("name", "age"))
df.select("*", sf.struct('age', df.name)).show()

+-----+---+-----------------+
| name|age|struct(age, name)|
+-----+---+-----------------+
|Alice|  2|       {2, Alice}|
|  Bob|  5|         {5, Bob}|
+-----+---+-----------------+