volgorde

Genereer een reeks gehele getallen van begin tot eind, incrementeel. Als de stap niet is ingesteld, wordt de functie verhoogd met 1 als het begin kleiner is dan of gelijk is aan stoppen, anders wordt de functie met 1 verminderd.

Syntaxis

from pyspark.sql import functions as sf

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

Parameterwaarden

Kenmerk	Typologie	Description
start	pyspark.sql.Column of str	De beginwaarde (inclusief) van de reeks.
stop	pyspark.sql.Column of str	De laatste waarde (inclusief) van de reeks.
step	pyspark.sql.Column of str, optioneel	De waarde die moet worden toegevoegd aan het huidige element om het volgende element in de reeks op te halen. De standaardwaarde is 1 als het begin kleiner is dan of gelijk is aan stoppen, anders -1.

Retouren

pyspark.sql.Column: Een nieuwe kolom die een matrix met reekswaarden bevat.

Voorbeelden

Voorbeeld 1: Een reeks genereren met standaardstap

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

Voorbeeld 2: Een reeks genereren met een aangepaste stap

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

Voorbeeld 3: Een reeks genereren met een negatieve stap

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