flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Using event timestamps
Date Mon, 14 Sep 2015 08:18:12 GMT
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 <balassi.marton@gmail.com>
wrote:

> 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 <gyfora@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
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message