t;(key, window, elements);
})
.keyBy(0)// use the same key as the windows
.mapWitState(...) // process the windows with shared information
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Transfer-information-from-one-window-
.n4.nabble.com/Transfer-information-from-one-window-to-the-next-tp11738p11766.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
function with the obtained
variable.
Regards,Xiaogang
--发件人:Sonex
发送时间:2017年2月20日(星期一) 19:54收件人:user
主 题:Re: 回复:Transfer information from one window to the
next
I don`t think you understood the question correctly. I do not care about
,
for key 1.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Transfer-information-from-one-window-to-the-next-tp11738p11739.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
rocess the windows
with shared information
Regards,Xiaogang
--发件人:Sonex
发送时间:2017年2月20日(星期一) 16:32收件人:user
主 题:Transfer information from one window to the next
val stream =
inputStream.assignAscendingTimestamps(_.eventTime)
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