Title here
Summary here
asc
asc(col)
asc - (ascending) - это функция в PySpark, которая используется для сортировки данных в порядке возрастания. Функция принимает один или несколько столбцов для сортировки и возвращает отсортированный DataFrame.
- Параметры
col: Column or str. имя столбца или список имен столбцов, которые нужно отсортировать в порядке возрастания.- Возвращает
Column- отсортированную колонку по возрастанию
asc sort example
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName("sort_asc_example").getOrCreate()
# Создание DataFrame
data = [("pyton", 25), ("java", 20), ("pyspark", 30)]
df = spark.createDataFrame(data, ["lang", "position"])
df.show()
+------+--------+
| lang|position|
+------+--------+
| pyton| 25|
| java| 20|
|pyspark| 30|
+------+--------+
# Сортировка данных по столбцу "position" в порядке возрастания
sorted_df = df.sort(df.position.asc())
# Вывод отсортированного DataFrame
sorted_df.show()
+------+--------+
| lang|position|
+------+--------+
| java| 20|
| pyton| 25|
|pyspark| 30|
+------+--------+
pyspark asc
| Добавлено в версии | 1.3.0. |
| Обновлено в версии | 3.4.0. |