Hi Aljoscha,
Thank you very much!
We imagined it's going to be very expensive to achieve that, and your
answer verified our understanding of how Flink works.
Regards,
Bowen
On Fri, Aug 25, 2017 at 8:18 AM, Aljoscha Krettek
wrote:
> Hi,
>
> I'm afraid this is not possible right now because it
Hi,
I'm afraid this is not possible right now because it would require keeping
state in the WindowAssigner (per key) about what the start timestamp for a
specific key is.
I think you could emulate that behaviour by having a stateful FlatMap that
keeps track of all keys and their respective tim
