August 11, 2020

Spark windows functions (II)

En el post anterior pudimos utilizar las funciones de ventanas para realizar agregados de sumas sobre ventanas temporales. Ahora, me gustaría utilizar otro ejemplo de analítica: Comparar con datos previos.

Pongamos que queremos analizar las ventas de un producto en diversos periodos de tiempo. Es decir, nos interesa saber si ahora vende más o menos que antes.

Para ello partiremos de una tabla de ventas:

DateKey ProductId Sales

Ahora que tenemos esto nos interesaría agrupar para cada producto sus ventas

2017-2022 Adrián Abreu powered by Hugo and Kiss Theme