Bagikan melalui


sort_array

Mengurutkan array input dalam urutan naik atau turun sesuai dengan urutan alami elemen array. Elemen null akan ditempatkan di awal array yang dikembalikan dalam urutan naik atau di akhir array yang dikembalikan dalam urutan menurun.

Syntax

from pyspark.sql import functions as sf

sf.sort_array(col, asc=True)

Parameter-parameternya

Pengaturan Tipe Description
col pyspark.sql.Column atau str Nama kolom atau ekspresi.
asc bool, opsional Apakah akan mengurutkan dalam urutan naik atau turun. Jika asc true (default), maka pengurutan dalam urutan naik. Jika False, maka dalam urutan turun.

Pengembalian Barang

pyspark.sql.Column: Array yang diurutkan.

Examples

Contoh 1: Mengurutkan array dalam urutan naik

import pyspark.sql.functions as sf
df = spark.createDataFrame([([2, 1, None, 3],)], ['data'])
df.select(sf.sort_array(df.data)).show()
+----------------------+
|sort_array(data, true)|
+----------------------+
|       [NULL, 1, 2, 3]|
+----------------------+

Contoh 2: Mengurutkan array dalam urutan turun

import pyspark.sql.functions as sf
df = spark.createDataFrame([([2, 1, None, 3],)], ['data'])
df.select(sf.sort_array(df.data, asc=False)).show()
+-----------------------+
|sort_array(data, false)|
+-----------------------+
|        [3, 2, 1, NULL]|
+-----------------------+

Contoh 3: Mengurutkan array dengan satu elemen

import pyspark.sql.functions as sf
df = spark.createDataFrame([([1],)], ['data'])
df.select(sf.sort_array(df.data)).show()
+----------------------+
|sort_array(data, true)|
+----------------------+
|                   [1]|
+----------------------+

Contoh 4: Mengurutkan array kosong

from pyspark.sql import functions as sf
from pyspark.sql.types import ArrayType, StringType, StructField, StructType
schema = StructType([StructField("data", ArrayType(StringType()), True)])
df = spark.createDataFrame([([],)], schema=schema)
df.select(sf.sort_array(df.data)).show()
+----------------------+
|sort_array(data, true)|
+----------------------+
|                    []|
+----------------------+

Contoh 5: Mengurutkan array dengan nilai null

from pyspark.sql import functions as sf
from pyspark.sql.types import ArrayType, IntegerType, StructType, StructField
schema = StructType([StructField("data", ArrayType(IntegerType()), True)])
df = spark.createDataFrame([([None, None, None],)], schema=schema)
df.select(sf.sort_array(df.data)).show()
+----------------------+
|sort_array(data, true)|
+----------------------+
|    [NULL, NULL, NULL]|
+----------------------+