Hi, the follow code:
val text = env.socketTextStream(hostName, port)val words1 = text.map {
x => val res = x.split(",") (res.apply(0)->res.apply(1))}
val words2 = env.fromElements(("a","w1"),("a","w2"),("c","w3"),("d","w4"))
val joinedStream = words1 .co
Hi,
will words2 always remain constant? If yes, you don't have to create a
stream out of it and coGroup it, but you could simply pass the
collection to Map/FlatMap function and do the joining there without the
need of a window. Btw. you know that non-keyed global windows do not scale?
If I und
window cut the T1 and T2 do not
achieve mine goal,so i want to write my "GlobalWindows.create()".
and Flink's operator state i have no ideal for it,and really do not know how to
use it.can you give me a example.
- 原始邮件 -
发件人：Timo Walther
收件人：user@flink.apache.org
主题：Re:
to use it.can you give me a example.
- 原始邮件 -
发件人：Timo Walther
收件人：user@flink.apache.org
主题：Re: modify coGroup GlobalWindows GlobalWindow
日期：2016年09月06日 17点52分
Hi,
will words2 always remain constant? If yes, you don't have to create a
stream out of it and coGroup it, but you could si
