全部数据库微服务运维大数据机器学习搜索引擎消息队列面试刷题

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

提问者：帅平问题分类：大数据

Spark

发布于：3个月前 (12-15)

1 个回答

冷言冷语冷眼相对

触发器默认是上一个微批处理完成之后立即处理下一个微批，在实际的编码过程中我们可以直接设置，设置的对象是writeStream，例如：

writeStream.trigger(Trigger.ProcessingTime(0))

1、如果是0的话，代表的是尽可能快的执行，

2、如果数值大于0，则代表间隔这个时间进行执行，单位是毫秒。

发布于：3个月前 (12-15)

我来回答