min.
Renvoie la valeur minimale de l'expression dans un groupe.
Syntaxe
Python
from pyspark.sql import functions as sf
sf.min(col)
parameter
parameter | Type | Description |
|---|---|---|
|
| La colonne cible sur laquelle la valeur minimale est calculée. |
Renvoie
pyspark.sql.Column: Une colonne qui contient la valeur minimale calculée.
Exemples
Exemple 1 : compute la valeur minimale d'une colonne numérique
Python
import pyspark.sql.functions as sf
df = spark.range(10)
df.select(sf.min(df.id)).show()
Output
+-------+
|min(id)|
+-------+
| 0|
+-------+
Exemple 2 : compute la valeur minimale d'une colonne de chaîne.
Python
import pyspark.sql.functions as sf
df = spark.createDataFrame([("Alice",), ("Bob",), ("Charlie",)], ["name"])
df.select(sf.min("name")).show()
Output
+---------+
|min(name)|
+---------+
| Alice|
+---------+
Exemple 3 : Calculez la valeur minimale d'une colonne avec des valeurs nulles.
Python
import pyspark.sql.functions as sf
df = spark.createDataFrame([(1,), (None,), (3,)], ["value"])
df.select(sf.min("value")).show()
Output
+----------+
|min(value)|
+----------+
| 1|
+----------+
Exemple 4 : Calculer la valeur minimale d'une colonne dans un DataFrame groupé
Python
import pyspark.sql.functions as sf
df = spark.createDataFrame([("Alice", 1), ("Alice", 2), ("Bob", 3)], ["name", "value"])
df.groupBy("name").agg(sf.min("value")).show()
Output
+-----+----------+
| name|min(value)|
+-----+----------+
|Alice| 1|
| Bob| 3|
+-----+----------+
**Exemple 5** : Calculez la valeur minimale d'une colonne dans un DataFrame avec plusieurs colonnes.
Python
import pyspark.sql.functions as sf
df = spark.createDataFrame(
[("Alice", 1, 100), ("Bob", 2, 200), ("Charlie", 3, 300)],
["name", "value1", "value2"])
df.select(sf.min("value1"), sf.min("value2")).show()
Output
+-----------+-----------+
|min(value1)|min(value2)|
+-----------+-----------+
| 1| 100|
+-----------+-----------+