Hi,
the input elements to a window function should not be modified. Could you
maybe achieve something using a Fold? Maybe if you went into a bit more
details we could figure something out together.
Cheers,
Aljoscha
On Tue, 16 Aug 2016 at 10:38 Ufuk Celebi wrote:
> Hey Paul! I think the window c
Hey Paul! I think the window content should not be updated. Still,
from looking at some of the internal Flink code, it looks like the
updates would affect the "data buffer" -- but I think that this is
only true for some cases and does not hold in general. Cc'ing Aljoscha
for a definite answer on th
Hello,
I'd like to specify a long time duration window (say 1 day) but write a custom
trigger to force processing on a more frequent interval (say 10 minutes).
Similar, at least initially, to the thread recently started by S. Carey (Firing
windows mulitple times). However, each time the win
