TableValuedFunction.stack

Oddziela col1, ..., colk na n wiersze. Domyślnie używa nazw kolumn col0, col1 itp., chyba że określono inaczej.

Składnia

spark.tvf.stack(n, *fields)

Parametry

Parameter	Typ	Description
n	pyspark.sql.Column	Liczba wierszy do oddzielenia.
fields	pyspark.sql.Column	Elementy wejściowe do oddzielenia.

Zwraca

pyspark.sql.DataFrame: Ramka danych ze skumulowanymi wierszami.

Przykłady

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