Tienes un DataFrame con operaciones ejecutadas (symbol, timestamp, price, quantity). Quieres calcular el VWAP (Volume Weighted Average Price) acumulado por día y símbolo sin perder el detalle fila a fila. ¿Qué usarías?

Question

Answer

Window.partitionBy("symbol", "date").orderBy("timestamp") y aplicar sum(price * quantity) y sum(quantity) como funciones de ventana

Answer

groupBy("symbol", "date").agg(sum(price * quantity) / sum(quantity))

Answer

distinct("symbol")

Answer

sort("timestamp").count()

Crowdly

Tienes un DataFrame con operaciones ejecutadas (symbol, timestamp, price, quanti...

Want instant access to all verified answers on sifo.comillas.edu?