spark结构化流处理中,如何设置触发器的时间间隔?

提问者:帅平 问题分类:大数据
spark结构化流处理中,如何设置触发器的时间间隔?
1 个回答
冷言冷语冷眼相对
冷言冷语冷眼相对
触发器默认是上一个微批处理完成之后立即处理下一个微批,在实际的编码过程中我们可以直接设置,设置的对象是writeStream,例如:
writeStream.trigger(Trigger.ProcessingTime(0))

1、如果是0的话,代表的是尽可能快的执行,
2、如果数值大于0,则代表间隔这个时间进行执行,单位是毫秒。
发布于:1年前 (2022-12-15) IP属地:四川省
我来回答