Interesting but how is this as an alternative to Apache Flink's stream processing model?
Flow's model doesn't use windows, and allows for long-distance (in time) joins and aggregations. There's no concept of "late" data in Flow: it just keeps on updating the desired aggregate.
This is if you want to use high level API. If you use lower-level ProcessFunction you have even more flexibility.