通过


TableValuedFunction.stack

col1... colk 分隔为 n 行。 默认情况下,除非另有指定,否则使用列名 col0、col1 等。

Syntax

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