Check out the first Dataiku 8 Deep Dive focusing on Productivity on October 29th Read More

Using Window recipe and moving average

Level 3
Using Window recipe and moving average

Hi - I am not sure that I understand how the window recipe works in terms of getting a moving average for the prior 3 months of data and I am hoping this can be clarified for me or there is a solution to what I want to do.

I attached a test_window.csv file that has 3 columns - id, month_year and total_hours.

What I want to do is get an average of the prior three months - see the last column of values I expect to see. Instead, I am not exactly sure what is being calculated (see test_window_prepared_windows.csv).

Thank you in advance for all the help!

idmonth_yeartotal_hoursprior 3 month avg
E1232018-01-01T00:00:00.000Z00
E1232018-02-01T00:00:00.000Z20
E1232018-03-01T00:00:00.000Z951
E1232018-05-01T00:00:00.000Z7.532
E1232018-06-01T00:00:00.000Z2535
E1232018-07-01T00:00:00.000Z6343

 

 

 

5 Replies
Level 5

Hi @aw30. The window logic, using any kind of tool (not only DSS), always confuses me and I've to go for a trial and error approach to try to understand it.

In this case you need to do a minor modification to your recipe to get the result you want:

Selection_342.png

So, besides limiting the number of preceding rows, you also had to limit the number of the following rows, and to limit to '-1', so the current row is not taken into account in the average calculated.

Before doing that, and by check the output you provided, the logic of the window recipe went like "group together all entries with the same id and order them by month. Then for each row, take the average of ALL the entries in the group after removing the entries that of rows that are 4 steps or more behind"

So for the first row of group with id E123, the average is taken over all the values (502.5/11 = 45.68), including the value of the first row; moving to the next row nothing changes, so again you get the same value, and the same for the 3rd and 4th row. For the 5th, your window constraint is applied, and the first value is removed, and now the average is 502.5/10 = 50.25, and the 6th row is 500.5/9 = 55.61, and so on.

Hope this helps!

Level 3
Author

Hi -thank you for the explanation this works!

0 Kudos
Level 5

My pleasure @aw30 !

0 Kudos
Level 1

Can I use the built in window logic to get a 7 day rolling average?

To get a rolling average I have been using a Python script but would rather use Dataiku features.

I posted by python script in this thread: https://community.dataiku.com/t5/Using-Dataiku-DSS/How-can-I-compute-an-exponential-moving-average-i...

 

0 Kudos

Hi @7TonRobot. I would say that yes, of course you could use it! In that case, depending on how you define the 7 day rolling average. From your python script, you are using the .rolling() method with the default options, where according to the pandas documentation "the result is set to the right edge of the window". This means that you should set the "Limiting Preceding rows" to 6 and "Limiting following rows" to 0.

Cheers!