inline_outer
Décompose un tableau de structs en une table. Contrairement à l'intégration, si le tableau est nul ou vide, alors une valeur nulle est produite pour chaque colonne imbriquée.
Syntaxe
Python
from pyspark.sql import functions as sf
sf.inline_outer(col)
parameter
parameter | Type | Description |
|---|---|---|
|
| Colonne d'entrée de valeurs à éclater. |
Renvoie
pyspark.sql.Column: expression de générateur avec le résultat éclaté intégré.
Exemples
Python
from pyspark.sql import functions as sf
df = spark.sql('SELECT * FROM VALUES (1,ARRAY(NAMED_STRUCT("a",1,"b",2), NULL, NAMED_STRUCT("a",3,"b",4))), (2,ARRAY()), (3,NULL) AS t(i,s)')
df.printSchema()
Output
root
|-- i: integer (nullable = false)
|-- s: array (nullable = true)
| |-- element: struct (containsNull = true)
| | |-- a: integer (nullable = false)
| | |-- b: integer (nullable = false)
Python
df.select('*', sf.inline_outer('s')).show(truncate=False)
Output
+---+----------------------+----+----+
|i |s |a |b |
+---+----------------------+----+----+
|1 |[{1, 2}, NULL, {3, 4}]|1 |2 |
|1 |[{1, 2}, NULL, {3, 4}]|NULL|NULL|
|1 |[{1, 2}, NULL, {3, 4}]|3 |4 |
|2 |[] |NULL|NULL|
|3 |NULL |NULL|NULL|
+---+----------------------+----+----+