seleccionar y agregar en pyspark en el ejemplo de código de marco de datos

Ejemplo 1: grupo pyspark por suma

from pyspark.sql import functions as func
prova_df.groupBy("order_item_order_id").agg(func.sum("order_item_subtotal")).show()

Ejemplo 2: agregación de Pyspark en varias columnas

df.groupBy("year", "sex").agg(avg("percent"), count("*"))

---

---

Utiliza Nuestro Buscador