Condividi tramite


TableValuedFunction.stack

col1Separa , ..., colk in n righe. Usa i nomi delle colonne col0, col1 e così via per impostazione predefinita, se non diversamente specificato.

Sintassi

spark.tvf.stack(n, *fields)

Parametri

Parametro TIPO Description
n pyspark.sql.Column Numero di righe da separare.
fields pyspark.sql.Column Elementi di input da separare.

Restituzioni

pyspark.sql.DataFrame: dataframe con le righe in pila.

Esempi

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