Thanks. The keyBy() splits the stream into multiple logical streams, if I do timeWindow(), then how flink merge all logical windows into one? When does the window functions get invoked? at the same time? or individually but flink wait for all window functions finished and merge the results?
2017-12-18 18:02 GMT+08:00 Fabian Hueske <fhue...@gmail.com>: > 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? > >
