TableValuedFunction.stack

col1Separa, ..., colk em n linhas. Usa nomes de coluna col0, col1 etc. por padrão, a menos que especificado o contrário.

Sintaxe

spark.tvf.stack(n, *fields)

Parâmetros

Parâmetro	Tipo	Description
n	pyspark.sql.Column	O número de linhas a serem separadas.
fields	pyspark.sql.Column	Elementos de entrada a serem separados.

Devoluções

pyspark.sql.DataFrame: Um DataFrame com as linhas empilhadas.

Exemplos

import pyspark.sql.functions as sf
spark.tvf.stack(sf.lit(2), sf.lit(1), sf.lit(2), sf.lit(3)).show()

+----+----+
|col0|col1|
+----+----+
|   1|   2|
|   3|NULL|
+----+----+