map_entries

Verilen eşlemedeki tüm girdilerden oluşan sıralanmamış bir dizi döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.map_entries(col)

Parametreler

Parametre	Türü	Description
col	pyspark.sql.Column veya str	Sütun veya ifadenin adı

İade

pyspark.sql.Column: Yapı türü olarak anahtar değer çiftleri dizisi

Örnekler

Örnek 1: Basit bir haritadan girdi ayıklama

from pyspark.sql import functions as sf
df = spark.sql("SELECT map(1, 'a', 2, 'b') as data")
df.select(sf.sort_array(sf.map_entries("data"))).show()

+-----------------------------------+
|sort_array(map_entries(data), true)|
+-----------------------------------+
|                   [{1, a}, {2, b}]|
+-----------------------------------+

Örnek 2: Karmaşık anahtarlar ve değerler içeren bir eşlemeden girdi ayıklama

from pyspark.sql import functions as sf
df = spark.sql("SELECT map(array(1, 2), array('a', 'b'), "
  "array(3, 4), array('c', 'd')) as data")
df.select(sf.sort_array(sf.map_entries("data"))).show(truncate=False)

+------------------------------------+
|sort_array(map_entries(data), true) |
+------------------------------------+
|[{[1, 2], [a, b]}, {[3, 4], [c, d]}]|
+------------------------------------+

Örnek 3: Boş bir eşlemeden girdi ayıklama

from pyspark.sql import functions as sf
df = spark.sql("SELECT map() as data")
df.select(sf.map_entries("data")).show()

+-----------------+
|map_entries(data)|
+-----------------+
|               []|
+-----------------+