You do not need windowing. You can do everything you want with regular KeyedStream. You can join not-windowed streams using IntervalJoin. This is if you want t

You do not need windowing. You can do everything you want with regular KeyedStream. You can join not-windowed streams using IntervalJoin. This is if you want to use high level API. If you use lower-level ProcessFunction you have even more flexibility.