分col1colk成n行列。 除非另有說明,否則預設使用欄位名稱 col0、col1 等。
語法
spark.tvf.stack(n, *fields)
參數
| 參數 | 類型 | Description |
|---|---|---|
n |
pyspark.sql.Column |
要分開的行數。 |
fields |
pyspark.sql.Column |
輸入元素需分離。 |
退貨
pyspark.sql.DataFrame:一個堆疊列的 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|
+----+----+