テーブル値関数.スタック

col1 、...、 colkをn行に分割します。特に指定がない限り、デフォルトでは列名 col0、col1 などが使用されます。

構文

Python

spark.tvf.stack(n, *fields)

パラメーター

パラメーター	Type	説明
n	pyspark.sql.Column	区切る行数。
fields	pyspark.sql.Column	分離する入力要素。

パラメーター	Type	説明
n	pyspark.sql.Column	区切る行数。
fields	pyspark.sql.Column	分離する入力要素。

戻り値

pyspark.sql.DataFrame: 積み重ねられた行を持つ DataFrame。

例

Python

import pyspark.sql.functions as sf
spark.tvf.stack(sf.lit(2), sf.lit(1), sf.lit(2), sf.lit(3)).show()

Output

+----+----+
|col0|col1|
+----+----+
|   1|   2|
|   3|NULL|
+----+----+