Hey Gyula, I have been recently looking at the streaming UdfOperators and can not recall a utility for the sources that you are looking for, but maybe I am also missing it. :) It would be a convenient addition though.
Best, Marton On Sun, Sep 13, 2015 at 8:59 PM, Gyula Fóra <gyf...@apache.org> wrote: > 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 >
