全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

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

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

Spark

发布于：2年前 (2022-12-15) IP属地：四川省

1 个回答

冷言冷语冷眼相对

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

writeStream.trigger(Trigger.ProcessingTime(0))

1、如果是0的话，代表的是尽可能快的执行，
2、如果数值大于0，则代表间隔这个时间进行执行，单位是毫秒。

发布于：2年前 (2022-12-15) IP属地：四川省

我来回答