简述SparkStreaming窗口函数的原理

2019-10-01  本文已影响0人  scott_alpha

窗口函数就是在原来定义的SparkStreaming计算批次大小的基础上再次进行封装,每次计算多个批次的数据,同时还需要传递一个滑动步长的参数,用来设置当次计算任务完成之后下一次从什么地方开始计算。

上一篇 下一篇

猜你喜欢

热点阅读