Compartir vía


struct

Crea una nueva columna de estructura.

Syntax

from pyspark.sql import functions as sf

sf.struct(*cols)

Parámetros

Parámetro Tipo Description
cols list, set pyspark.sql.Column o column name Nombres de columna o Columnas que se van a contener en la estructura de salida.

Devoluciones

pyspark.sql.Column: una columna de tipo de estructura de columnas dadas.

Examples

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