FWIW you might be interested in this, generalizing to many types of materialized views over increments of data via an equivalent of the chain rule over streams https://muratbuffalo.blogspot.com/2024/11/dbsp-automatic-inc...