estrutura_nomeada

Cria uma estrutura com os nomes e valores dos campos fornecidos.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.named_struct(*cols)

Parâmetros

Parâmetro	Tipo	Descrição
cols	pyspark.sql.Column ou nome da coluna	Lista de colunas para trabalhar.

Parâmetro	Tipo	Descrição
cols	pyspark.sql.Column ou nome da coluna	Lista de colunas para trabalhar.

Devoluções

pyspark.sql.Column:

Exemplos

Python

import pyspark.sql.functions as sf
df = spark.createDataFrame([(1, 2)], ['a', 'b'])
df.select("*", sf.named_struct(sf.lit('x'), df.a, sf.lit('y'), "b")).show()

Output

+---+---+------------------------+
|  a|  b|named_struct(x, a, y, b)|
+---+---+------------------------+
|  1|  2|                  {1, 2}|
+---+---+------------------------+