TableValuedFunction.stack

Отделяет col1, ..., colk в n строки. Использует имена столбцов col0, col1 и т. д. по умолчанию, если не указано иное.

Синтаксис

spark.tvf.stack(n, *fields)

Параметры

Параметр	Тип	Description
n	pyspark.sql.Column	Количество строк для разделения.
fields	pyspark.sql.Column	Входные элементы для разделения.

Возвраты

pyspark.sql.DataFrame: Кадр данных с строками с накоплением.

Примеры

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