flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyf...@apache.org>
Subject Re: Question about Streaming Windows in Join
Date Wed, 25 Mar 2015 17:43:00 GMT
Hey Aljoscha,

This is not an accident :D

The reason behind only supporting time-window joins at the moment, is
because time-window-joins can be implemented in a completely non-blocking
fashion arising from the global nature of time.

All other windows would need to be matched properly which inevitably needs
some blocking of channels or buffering up windows, neither of which is very
scalable for streams.

At some point I will try to work on unifying this one way or another but we
need to come up with some scalable solution for this.


On Wed, Mar 25, 2015 at 4:28 PM, Aljoscha Krettek <aljoscha@apache.org>

> Hi,
> I noticed that the way you specify windows for a join differs from the
> way you specify windows on a DataStream. Maybe I'm missing something
> here. :D
> If not, is there are reason for this behaviour? Are there any plans to
> consolidate?
> Cheers,
> Aljoscha

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message