Re: Using event timestamps

2015-09-14 Thread Gyula Fóra
Then as a first step, I will open a Jira for it :) Aljoscha Krettek ezt írta (időpont: 2015. szept. 14., H, 10:18): > Hi, > there is nothing like that in there yet but it would be very nice to have > it. :D Also, as far as I know no-one is working on this right now. > >

Re: Using event timestamps

2015-09-14 Thread Aljoscha Krettek
Hi, there is nothing like that in there yet but it would be very nice to have it. :D Also, as far as I know no-one is working on this right now. Cheers, Aljoscha On Mon, 14 Sep 2015 at 06:27 Márton Balassi wrote: > Hey Gyula, > > I have been recently looking at the

Using event timestamps

2015-09-13 Thread Gyula Fóra
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

Re: Using event timestamps

2015-09-13 Thread Márton Balassi
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