结构

创建新的结构列。

Syntax

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}|
+-----+---+-----------------+