slice

Giriş dizisi sütununu bir başlangıç dizininden belirli bir uzunluğa dilimleyerek yeni bir dizi sütunu döndürür. Dizinler 1'den başlar ve dizinin sonundan dizine negatif olabilir. Uzunluk, sonuçta elde edilen dizideki öğelerin sayısını belirtir.

Sözdizimi

from pyspark.sql import functions as sf

sf.slice(x, start, length)

Parametreler

Parametre	Türü	Description
x	pyspark.sql.Column veya str	Dilimlenecek dizi sütununu veya sütun adını girin.
start	pyspark.sql.Column, str veya int	Dilim işleminin başlangıç dizini. Negatifse dizini dizinin sonundan başlatır.
length	pyspark.sql.Column, str veya int	Elde edilen dizideki öğe sayısını temsil eden dilimin uzunluğu.

İade

pyspark.sql.Column: Her değerin giriş sütunundan ilgili listenin bir dilimi olduğu Dizi türünde yeni bir Column nesnesi.

Örnekler

Örnek 1: Dilim işlevinin temel kullanımı.

from pyspark.sql import functions as sf
df = spark.createDataFrame([([1, 2, 3],), ([4, 5],)], ['x'])
df.select(sf.slice(df.x, 2, 2)).show()

+--------------+
|slice(x, 2, 2)|
+--------------+
|        [2, 3]|
|           [5]|
+--------------+

Örnek 2: Negatif başlangıç diziniyle dilimleme.

from pyspark.sql import functions as sf
df = spark.createDataFrame([([1, 2, 3],), ([4, 5],)], ['x'])
df.select(sf.slice(df.x, -1, 1)).show()

+---------------+
|slice(x, -1, 1)|
+---------------+
|            [3]|
|            [5]|
+---------------+

Örnek 3: Başlangıç ve uzunluk için sütun girişleri içeren dilim işlevi.

from pyspark.sql import functions as sf
df = spark.createDataFrame([([1, 2, 3], 2, 2), ([4, 5], 1, 3)], ['x', 'start', 'length'])
df.select(sf.slice(df.x, df.start, df.length)).show()

+-----------------------+
|slice(x, start, length)|
+-----------------------+
|                 [2, 3]|
|                 [4, 5]|
+-----------------------+