flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hery168 <hery...@163.com>
Subject 关于Flink 中 timeWindow 滚动窗口边界和数据延迟问题疑惑
Date Thu, 21 Feb 2019 09:44:13 GMT
今天看网上的一篇文章https://blog.csdn.net/xsdxs/article/details/82415450#commentsedit
<https://blog.csdn.net/xsdxs/article/details/82750254>
很感谢作者的整理,感觉不错,对里面的一些内容不是很理解
文章的
3.1.3 输出

1 -> 1000000050000 -> 2001-09-09 09:47:30.000
2 -> 1000000054000 -> 2001-09-09 09:47:34.000
3 -> 1000000079900 -> 2001-09-09 09:47:59.900
(a,12,1)
4 -> 1000000120000 -> 2001-09-09 09:48:40.000
(a,3,1000000079900)
5 -> 1000000111000 -> 2001-09-09 09:48:31.000
6 -> 1000000089000 -> 2001-09-09 09:48:09.000
(b,5,1000000111000)
(a,4,1000000120000)

代码的resStream.print();对reduce函数里的内容进行了处理,返回为Tuple3.of(value1.f0,
value1.f1 + "" + value2.f1, 1L);,开始打印出的数据中,包含(a,3,1000000079900)
(b,5,1000000111000)
(a,4,1000000120000)
这些原始数据是怎么输出的?,这些数据是否进reduce函数?
望各位大神帮忙解答一下。
最后感谢文章的作者
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message