Executing detached data stream programs

? Thanks, Jordan Ganoff smime.p7s Description: S/MIME cryptographic signature

Watermarks per key

Hi, I’m designing a streaming job whose elements need to be windowed by event time across a large set of keys. All elements are read from the same source. Event time progresses independently across keys. Is it possible to assign timestamps, and thus generate independent watermarks, per keyed st