flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: Using event timestamps
Date Mon, 14 Sep 2015 04:26:51 GMT
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