TableValuedFunction.explode_outer

Devuelve un DataFrame que contiene una nueva fila para cada elemento con posición en la matriz o mapa especificados. A diferencia de la explosión, si la matriz o mapa es null o está vacía, se genera null. Usa el nombre col de columna predeterminado para los elementos de la matriz y key para los value elementos del mapa, a menos que se especifique lo contrario.

Syntax

spark.tvf.explode_outer(collection)

Parámetros

Parámetro	Tipo	Description
collection	pyspark.sql.Column	Columna de destino en la que trabajar.

Devoluciones

pyspark.sql.DataFrame: DataFrame con una nueva fila para cada elemento o null si la colección está vacía o null.

Examples

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|
+----+-----+