val stream =
inputStream.assignAscendingTimestamps(_.eventTime).keyBy(_.inputKey).timeWindow(Time.seconds(3600),Time.seconds(3600))
stream.apply{...}
Given the above example I want to transfer information (variables and
values) from the current apply function to the apply function of the next
window (of course with the same key).
How can I do that?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Transfer-information-from-one-window-to-the-next-tp11737.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
