This seems conceptually similar to differential dataflow.

https://github.com/timelydataflow/differential-dataflow/blob...