TableValuedFunction.explode_outer

Egy dataFrame-et ad vissza, amely egy új sort tartalmaz minden olyan elemhez, amely az adott tömbben vagy térképen található pozícióval rendelkezik. A robbantástól eltérően, ha a tömb/térkép null vagy üres, akkor null érték jön létre. Az alapértelmezett oszlopnevet col használja a tömb elemeihez és keyvalue a térkép elemeihez, kivéve, ha másként van megadva.

Szemantika

spark.tvf.explode_outer(collection)

Paraméterek

Paraméter	Típus	Description
collection	pyspark.sql.Column	Céloszlop, amelyen dolgozni szeretne.

Visszatérítések

pyspark.sql.DataFrame: Adatkeret minden elemhez új sortal, vagy null értékű, ha a gyűjtemény üres vagy null értékű.

Példák

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