Re: Window over events defined by a time range

2018-05-03 Thread Fabian Hueske
Hi, Flink can add events to mulitple windows. For instance, the built-in sliding windows are doing this. You can address your use case by implementing a custom WindowAssigner [1]. Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/windows.html#windo

Window over events defined by a time range

2018-05-02 Thread Padarn Wilson
Hi all, I'm trying to figure out what the "Flink" way of achieving what I'd like to is. Imagine I have the following three events in my stream event1: {"start_time": 0, "end_time": 1, "value": "a"} event2: {"start_time": 0, "end_time": 2, "value": "b"} event3: {"start_time": 1, "end_time": 2, "v