szekvencia

Egész számok sorozatának létrehozása az elejétől a leállásig, lépésenkénti növekményekkel. Ha a lépés nincs beállítva, a függvény 1-gyel növekszik, ha a kezdés kisebb vagy egyenlő a leállításnál, ellenkező esetben 1-gyel csökken.

Szemantika

from pyspark.sql import functions as sf

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

Paraméterek

Paraméter	Típus	Description
start	pyspark.sql.Column vagy str	A sorozat kezdőértéke (a sorrendet is beleértve).
stop	pyspark.sql.Column vagy str	A sorozat utolsó értéke (a teljes értéket is beleértve).
step	pyspark.sql.Column vagy str, nem kötelező	Az az érték, amely hozzáadva van az aktuális elemhez a sorozat következő elemének lekéréséhez. Az alapértelmezett érték 1, ha az indítás kisebb vagy egyenlő a leállításnál, ellenkező esetben -1.

Visszatérítések

pyspark.sql.Column: Egy új oszlop, amely szekvenciaértékeket tartalmazó tömböt tartalmaz.

Példák

1. példa: Sorozat létrehozása alapértelmezett lépéssel

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]|
+---------------------+

2. példa: Sorozat létrehozása egyéni lépéssel

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]|
+---------------------------+

3. példa: Sorozat létrehozása negatív lépéssel

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]|
+---------------------------+