produit
Renvoie le produit des valeurs d'un groupe.
Syntaxe
Python
from pyspark.sql import functions as sf
sf.product(col)
parameter
parameter | Type | Description |
|---|---|---|
|
| Colonne contenant les valeurs à multiplier. |
Renvoie
pyspark.sql.Column: la colonne pour les résultats calculés.
Exemples
Python
from pyspark.sql import functions as sf
df = spark.sql("SELECT id % 3 AS mod3, id AS value FROM RANGE(10)")
df.groupBy('mod3').agg(sf.product('value')).orderBy('mod3').show()
Output
+----+--------------+
|mod3|product(value)|
+----+--------------+
| 0| 0.0|
| 1| 28.0|
| 2| 80.0|
+----+--------------+