滑动窗口在流计算中实践与优化.pdfVIP

计算在天猫双11的实践》

7、滑动窗口SlidingWindow

的实战案例

讲师：Cloudy

作室页数

算在天猫双11的实践》

7、滑动窗口SlidingWindow的

战案例

授课老师：多云

页数

滑动窗口SlidingWindow，场景多

长度，可以是时间或Tuple数量；

长(slidingInterval)，计算频率，同样也可以是时间或Tuple数量。

个窗口，滑动5s，效果如下：

口数据是有的！属于“去头留尾”的计算。

dowedBolt.withWindow(CountwindowLength,CountslidingInterval)

滑动窗口滑动窗口，场景多

的⻓度，可以是时间或元组数量；

步⻓(slidingInterval)，计算频率，同样也可以是时间或元组数量。

⼀个窗⼝，滑动5s，效果如下：

⼝数据是有的！属于“去头留尾”的计算。

dowedBolt.withWindow(计数窗⼝⻓度,计数滑动间隔)

10个Tuple，步长大小为5个Tuple，计算销售额。

通过时间定义和数量定义有什么优劣？

，订单产生或其他数据产生都是存在闲忙时，通过时间段定窗口的话忙时计算大。

数据定窗口的话，不受闲忙时的影响。

parkStreaming就是按时间片的批处理。

10个Tuple，步⻓大小为5个Tuple，计算销售额。

按时间定义和数量定义有什么优劣？业务上、订单产生或其他数据产生都是存在闲忙时，

段定窗⼝忙时计算大。

数据设定窗⼝时，不受闲忙时的影响。

parkStreaming就是按时间片的批处理。

小结