TableValuedFunction.explode_outer

Retourneert een DataFrame met een nieuwe rij voor elk element met positie in de opgegeven matrix of kaart. In tegenstelling tot exploderen, als de matrix/kaart null of leeg is, wordt null geproduceerd. Hiermee wordt de standaardkolomnaam col gebruikt voor elementen in de matrix en keyvalue voor elementen in de kaart, tenzij anders is opgegeven.

Syntaxis

spark.tvf.explode_outer(collection)

Parameterwaarden

Kenmerk	Typologie	Description
collection	pyspark.sql.Column	Doelkolom waaraan moet worden gewerkt.

Retouren

pyspark.sql.DataFrame: Een DataFrame met een nieuwe rij voor elk element of null als de verzameling leeg of null is.

Voorbeelden

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