TableValuedFunction.inline

Bir yapı dizisini bir tabloya ayrıştırır.

Bu işlev, bir yapı dizisi içeren bir giriş sütunu alır ve dizideki her yapının ayrı bir satıra ayrıldığı yeni bir sütun döndürür.

Sözdizimi

spark.tvf.inline(input)

Parametreler

Parametre	Türü	Description
input	pyspark.sql.Column	Patlayacak değerlerin sütununu girin.

İade

pyspark.sql.DataFrame: Patlayan yapı satırlarına sahip bir DataFrame.

Örnekler

Örnek 1: Tek bir yapı dizisiyle satır içi kullanma

import pyspark.sql.functions as sf
spark.tvf.inline(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|
+---+---+

Örnek 2: Boş bir yapı dizisi sütunuyla satır içi kullanma

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

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

Örnek 3: Null değerler içeren bir yapı dizisi sütunuyla satır içi kullanma

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

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