flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jinhua Luo <luajit...@gmail.com>
Subject how flink extracts timestamp from transformed elements?
Date Sat, 16 Dec 2017 08:01:57 GMT
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?

Mime
View raw message