My app is calculating Companies scores from Ratings given by users.
Only ratings from last 90 days should be considered.
1. Is it possible to construct window processing ratings from last 90 days?
I've started with *misusing* countWindow but this solution looks ugly for
2. How to recalculate score once the rating expires (after 90 days)?
I don't want to put artificial ratings into the stream to trigger the
Any idea how can I do it better?