Hi,
I'm sorry but I still think this is not possible. Windows are usually
associated with a key, so if there is no element to which we can assign a
window then there is also no key to which the window would belong.
Cheers,
Aljoscha
On Thu, 21 Apr 2016 at 22:35 Maxim wrote:
> I think the best wa
I think the best way to support such a feature is to extend WindowAssigner
with ability to be called on timer and checkpoint its state the same way it
is done by the Trigger.
Such WindowAssigner would be able to create Windows based on time even if
no event is received.
On Thu, Apr 21, 2016 at 1:5
Hi,
I'm afraid this is not possible with our windowing model (expect with hacks
using GlobalWindow, as you mentioned). The reason is, that windows only
come into existence once there is an element that has a window. Before
that, the system has no reference point about what windows there should
exis
I have the following use case:
Input stream of timestamped "on" and "off" events received out of order.
I need to produce an event with time that system was "on" every 15 minutes.
Events should be produced only for intervals that system was "on".
When 15 minute window has at least one record it i
