map_entries
Renvoie un tableau non ordonné de toutes les entrées de la carte donnée.
Syntaxe
Python
from pyspark.sql import functions as sf
sf.map_entries(col)
parameter
parameter | Type | Description |
|---|---|---|
|
| Nom de colonne ou d'expression |
Renvoie
pyspark.sql.Column: Tableau de paires clé-valeur en tant que type de structure
Exemples
Exemple 1 : Extraction d'entrées à partir d'un mappage simple
Python
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()
Output
+-----------------------------------+
|sort_array(map_entries(data), true)|
+-----------------------------------+
| [{1, a}, {2, b}]|
+-----------------------------------+
Exemple 2 : Extraction d'entrées d'une carte avec des clés et des valeurs complexes
Python
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)
Output
+------------------------------------+
|sort_array(map_entries(data), true) |
+------------------------------------+
|[{[1, 2], [a, b]}, {[3, 4], [c, d]}]|
+------------------------------------+
Exemple 3 : Extraction d'entrées d'une carte vide
Python
from pyspark.sql import functions as sf
df = spark.sql("SELECT map() as data")
df.select(sf.map_entries("data")).show()
Output
+-----------------+
|map_entries(data)|
+-----------------+
| []|
+-----------------+