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
