テーブル値関数.posexplode

指定された配列またはマップ内の位置にある各要素の新しい行を含む DataFrame を返します。特に指定がない限り、位置にはデフォルトの列名posを使用し、配列内の要素にはcol 、マップ内の要素にはkeyとvalue使用します。

構文

Python

spark.tvf.posexplode(collection)

パラメーター

パラメーター	Type	説明
collection	pyspark.sql.Column	取り組むターゲットカラム。

戻り値

pyspark.sql.DataFrame: 各要素の新しい行とその位置を持つ DataFrame。

例

Python

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

Output

+---+---+
|pos|col|
+---+---+
|  0|  1|
|  1|  2|
|  2|  3|
+---+---+

Python

import pyspark.sql.functions as sf
spark.tvf.posexplode(sf.create_map(sf.lit("a"), sf.lit("b"))).show()

Output

+---+---+-----+
|pos|key|value|
+---+---+-----+
|  0|  a|    b|
+---+---+-----+