TableValuedFunction.posexplode

Verilen dizide veya eşlemede konumu olan her öğe için yeni bir satır içeren bir DataFrame döndürür. 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(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.

Örnekler

import pyspark.sql.functions as sf
spark.tvf.posexplode(sf.array(sf.lit(1), sf.lit(2), sf.lit(3))).show()

+---+---+
|pos|col|
+---+---+
|  0|  1|
|  1|  2|
|  2|  3|
+---+---+

import pyspark.sql.functions as sf
spark.tvf.posexplode(sf.create_map(sf.lit("a"), sf.lit("b"))).show()

+---+---+-----+
|pos|key|value|
+---+---+-----+
|  0|  a|    b|
+---+---+-----+