produto
Retorna o produto dos valores em um grupo.
Sintaxe
Python
from pyspark.sql import functions as sf
sf.product(col)
Parâmetros
Parâmetro | Tipo | Descrição |
|---|---|---|
|
| Coluna contendo os valores a serem multiplicados entre si. |
Devoluções
pyspark.sql.Column: a coluna para resultados de cálculo.
Exemplos
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|
+----+--------------+