TableValuedFunction.stack

Sépare col1, ..., colk en n lignes. Utilise les noms de colonne col0, col1, etc. default, sauf indication contraire.

Syntaxe

Python

spark.tvf.stack(n, *fields)

parameter

parameter	Type	Description
n	pyspark.sql.Column	Le nombre de lignes à séparer.
fields	pyspark.sql.Column	Éléments d'entrée à séparer.

parameter	Type	Description
n	pyspark.sql.Column	Le nombre de lignes à séparer.
fields	pyspark.sql.Column	Éléments d'entrée à séparer.

Renvoie

pyspark.sql.DataFrame: Un DataFrame avec les lignes empilées.

Exemples

Python

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

Output

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