TableValuedFunction.explode_outer

지정된 배열 또는 맵에 위치가 있는 각 요소에 대한 새 행이 포함된 DataFrame을 반환합니다. 분해와 달리 배열/맵이 null이거나 비어 있으면 null이 생성됩니다. 달리 지정하지 않는 한 배열의 요소 및 keyvalue 맵의 요소에 대한 기본 열 이름을 col 사용합니다.

문법

spark.tvf.explode_outer(collection)

매개 변수

매개 변수	유형	Description
collection	pyspark.sql.Column	작업할 대상 열입니다.

Returns

pyspark.sql.DataFrame: 각 요소에 대해 새 행이 있는 DataFrame이거나, 컬렉션이 비어 있거나 null인 경우 null입니다.

예시

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

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

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

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

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

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

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

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