array_min(col)

Описание

Функция array_min() возвращает минимальное значение в массиве. Для строковых значений используется лексикографический порядок.

Параметры

col: Column - массив для поиска минимального значения

Возвращаемое значение

Any - минимальное значение в массиве

Пример использования

from pyspark.sql.functions import array_min, array, lit

# Создаем DataFrame с массивами
df = spark.createDataFrame([
    ([1, 2, 3, 4],),
    (["a", "b", "c"],),
    ([None, 1, 2],),
    (None,)
], ["array_col"])

# Находим минимальные значения
df.select(
    "array_col",
    array_min("array_col").alias("min_value")
).show(truncate=False)

# Результат:
# +------------+---------+
# |array_col   |min_value|
# +------------+---------+
# |[1, 2, 3, 4]|1        |
# |[a, b, c]   |a        |
# |[null, 1, 2]|1        |
# |null        |null     |
# +------------+---------+

# Пример с разными типами данных
df = spark.createDataFrame([
    ([1.0, 2.0, 3.0],),
    ([True, False],),
    ([None, 1],)
], ["values"])

df.select(
    "values",
    array_min("values").alias("min_value")
).show(truncate=False)