sıra

Baştan sona, adım adım artan bir tamsayı dizisi oluşturun. Adım ayarlanmazsa, başlatma durdurulmaya eşit veya ondan küçükse işlev 1 artar, aksi takdirde 1 azalır.

Sözdizimi

from pyspark.sql import functions as sf

sf.sequence(start, stop, step=None)

Parametreler

Parametre Türü Description
start pyspark.sql.Column veya str Dizinin başlangıç değeri (dahil).
stop pyspark.sql.Column veya str Dizinin son değeri (dahil).
step pyspark.sql.Column veya str, isteğe bağlı Dizideki sonraki öğeyi almak için geçerli öğeye eklenecek değer. Başlangıç durdurulmaya eşit veya ondan küçükse varsayılan değer 1'dir, aksi takdirde -1 olur.

İade

pyspark.sql.Column: Dizi değerleri dizisi içeren yeni bir sütun.

Örnekler

Örnek 1: Varsayılan adımla bir dizi oluşturma

import pyspark.sql.functions as sf
df = spark.createDataFrame([(-2, 2)], ['start', 'stop'])
df.select(sf.sequence(df.start, df.stop)).show()

+---------------------+
|sequence(start, stop)|
+---------------------+
|    [-2, -1, 0, 1, 2]|
+---------------------+

Örnek 2: Özel bir adımla sıra oluşturma

import pyspark.sql.functions as sf
df = spark.createDataFrame([(4, -4, -2)], ['start', 'stop', 'step'])
df.select(sf.sequence(df.start, df.stop, df.step)).show()

+---------------------------+
|sequence(start, stop, step)|
+---------------------------+
|          [4, 2, 0, -2, -4]|
+---------------------------+

Örnek 3: Negatif adımla dizi oluşturma

import pyspark.sql.functions as sf
df = spark.createDataFrame([(5, 1, -1)], ['start', 'stop', 'step'])
df.select(sf.sequence(df.start, df.stop, df.step)).show()

+---------------------------+
|sequence(start, stop, step)|
+---------------------------+
|            [5, 4, 3, 2, 1]|
+---------------------------+
  • Last updated on