col1 ...colk を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|
+----+----+