You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 浪人 <15...@qq.com> on 2019/02/28 05:56:01 UTC

回复:flink wordcount中 sum是在什么时候,哪个地方调用的?

这个要看你具体的实现方式的。




------------------ 原始邮件 ------------------
发件人: " "<th...@yahoo.com.INVALID>;
发送时间: 2019年2月28日(星期四) 中午1:04
收件人: "user-zh@flink.apache.org"<us...@flink.apache.org>;

主题: flink wordcount中      sum是在什么时候,哪个地方调用的?



请问:   flink wordcount中      sum是在什么时候,哪个地方调用的?

回复:flink wordcount中 sum是在什么时候,哪个地方调用的?

Posted by 浪人 <15...@qq.com>.
方案一:是使用window计算,那么就会在窗口结束时候累计。
方案二:是使用processfuntion做,在每个事件达到是做聚合。


------------------ 原始邮件 ------------------
发件人: "康仔仔"<15...@qq.com>;
发送时间: 2019年2月28日(星期四) 中午1:56
收件人: "user-zh"<us...@flink.apache.org>;

主题: 回复:flink wordcount中      sum是在什么时候,哪个地方调用的?



这个要看你具体的实现方式的。




------------------ 原始邮件 ------------------
发件人: " "<th...@yahoo.com.INVALID>;
发送时间: 2019年2月28日(星期四) 中午1:04
收件人: "user-zh@flink.apache.org"<us...@flink.apache.org>;

主题: flink wordcount中      sum是在什么时候,哪个地方调用的?



请问:   flink wordcount中      sum是在什么时候,哪个地方调用的?