Hi, timestamps are handled as meta-data in Flink's DataStream API. This means that Flink automatically maintains the timestamps and ensures that all records which were aligned with the watermarks (i.e., not late) are still aligned. If records are aggregated in a time window, the aggregation results has the maximum allowed timestamp of the window. For example a tumbling window of size 1 hour that starts at 14:00 emits its results with a timestamp of 14:59:59.999.
Best, Fabian 2017-12-16 9:01 GMT+01:00 Jinhua Luo <luajit...@gmail.com>: > Hi All, > > The timestamp assigner is for one type, normally for the type from the > source, but after several operators, the element type would change and > the elements would be aggregated, if I do timeWindow again, how flink > extracts timestamp from elements? For example, the fold operators > aggregate 10 source elements into one, it would copy the last > element's timestamp to the result element? >
