flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyf...@apache.org>
Subject Using event timestamps
Date Sun, 13 Sep 2015 18:59:36 GMT
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 :)


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