次の方法で共有


TableValuedFunction.inline_outer

構造体の配列をテーブルに展開します。 インラインとは異なり、配列が null または空の場合、入れ子になった列ごとに null が生成されます。

構文

spark.tvf.inline_outer(input)

パラメーター

パラメーター タイプ Description
input pyspark.sql.Column 分解する値の入力列。

返品ポリシー

pyspark.sql.DataFrame: 分解された構造体行を含む DataFrame。配列が空または null の場合は null 値。

例示

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()
+---+---+
|  a|  b|
+---+---+
|  1|  2|
|  3|  4|
+---+---+
import pyspark.sql.functions as sf
spark.tvf.inline_outer(sf.array().astype("array<struct<a:int,b:int>>")).show()
+----+----+
|   a|   b|
+----+----+
|NULL|NULL|
+----+----+