テーブル値関数.explode_outer

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

構文

Python

spark.tvf.explode_outer(collection)

パラメーター

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

戻り値

pyspark.sql.DataFrame: 各要素ごとに新しい行を持つ DataFrame。コレクションが空または null の場合は null になります。

例

Python

import pyspark.sql.functions as sf
spark.tvf.explode_outer(sf.array(sf.lit("foo"), sf.lit("bar"))).show()

Output

+---+
|col|
+---+
|foo|
|bar|
+---+

Python

import pyspark.sql.functions as sf
spark.tvf.explode_outer(sf.array()).show()

Output

+----+
| col|
+----+
|NULL|
+----+

Python

import pyspark.sql.functions as sf
spark.tvf.explode_outer(sf.create_map(sf.lit("x"), sf.lit(1.0))).show()

Output

+---+-----+
|key|value|
+---+-----+
|  x|  1.0|
+---+-----+

Python

import pyspark.sql.functions as sf
spark.tvf.explode_outer(sf.create_map()).show()

Output

+----+-----+
| key|value|
+----+-----+
|NULL| NULL|
+----+-----+