構造体

新しい構造体の列を作成します。

構文

Python

from pyspark.sql import functions as sf

sf.struct(*cols)

パラメーター

パラメーター	Type	説明
cols	リスト、セット、 pyspark.sql.Column 、または列名	出力構造体に含める列名または列。

戻り値

pyspark.sql.Column: 指定された列の構造体型の列。

例

Python

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

Output

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