Hey All! Is there a proper way of using a Flink Streaming source with event timestamps and watermarks? What I mean here is instead of implementing a custom SourceFunction, use an existing one and provide some Timestamp extractor (like the one currently used for Time windows), which will also automatically generate the watermarks based on event time (assuming that timestamps are partially ordered).
Maybe I missed something, or there might be somebody working on this already :) Cheers, Gyula
