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