TableValuedFunction.posexplode_outer

Verilen dizide veya eşlemede konumu olan her öğe için yeni bir satır içeren bir DataFrame döndürür. Posexplode'un aksine, dizi/eşleme null veya boşsa satır (null, null) oluşturulur. Konum ve dizideki poscol öğeler için ve key aksi belirtilmedikçe eşlemedeki öğeler için varsayılan sütun adını value kullanır.

Sözdizimi

spark.tvf.posexplode_outer(collection)

Parametreler

Parametre	Türü	Description
collection	pyspark.sql.Column	Üzerinde çalışacak hedef sütun.

İade

pyspark.sql.DataFrame: Konumuyla birlikte her öğe için yeni bir satır içeren bir DataFrame veya koleksiyon boş veya null ise null değerler.

Örnekler

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

+---+---+
|pos|col|
+---+---+
|  0|foo|
|  1|bar|
+---+---+

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

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

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

+---+---+-----+
|pos|key|value|
+---+---+-----+
|  0|  x|  1.0|
+---+---+-----+

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

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