TableValuedFunction.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

spark.tvf.inline_outer(input)

parameter

parameter	Type	Description
input	pyspark.sql.Column	Colonne d'entrée de valeurs à éclater.

parameter	Type	Description
input	pyspark.sql.Column	Colonne d'entrée de valeurs à éclater.

Renvoie

pyspark.sql.DataFrame: Un DataFrame avec des lignes de struct éclatées, ou des valeurs nulles si le tableau est vide ou nul.

Exemples

Python

import pyspark.sql.functions as sf
spark.tvf.inline_outer(sf.array(
    sf.named_struct(sf.lit("a"), sf.lit(1), sf.lit("b"), sf.lit(2)),
    sf.named_struct(sf.lit("a"), sf.lit(3), sf.lit("b"), sf.lit(4))
)).show()

Output

+---+---+
|  a|  b|
+---+---+
|  1|  2|
|  3|  4|
+---+---+

Python

import pyspark.sql.functions as sf
spark.tvf.inline_outer(sf.array().astype("array<struct<a:int,b:int>>")).show()

Output

+----+----+
|   a|   b|
+----+----+
|NULL|NULL|
+----+----+