Hi Mathieu,
The easiest way is to already emit several inputs on the source level. If
you use DeserializationSchema, try to use the method with the collector.
The watermarks should then be generated as if you would only receive one
element at a time.
On Sun, Apr 18, 2021 at 11:08 AM Mathieu D wr
Hi,
I can't change the way devices send their data. We are constrained in the
messages sent per day per device.
To illustrate my question:
- at 9:08 a message is emitted. It packs together several measures:
- measure m1 taken at 8:52
- measure m2 taken at 9:07
m1 must go in the 8:00-9:00 aggrega
Hello,
I'm totally new to Flink, and I'd like to make sure I understand things
properly around watermarks.
We're processing messages from iot devices.
Those messages have a timestamp, and we have a first phase of processing
based on this timestamp. So far so good.
These messages actually "pack"
