数据流是否支持自定义触发器或更新触发器延迟？

Question

TL:DR;是否可以创建一个仅在设置了某些标志时才触发的自定义触发器？是否可以在我们知道正在发生大数据事件时使用具有巨大延迟的触发器部署作业，然后在该事件完成后使用具有正常延迟或无延迟的触发器将更新部署到作业？

后续来自：

这种情况最容易发生（数百万次重复触发）是在我们回填旧数据时。鉴于我们知道这是什么时候发生的，我想知道我们是否可以实现一个在设置标志时不触发的自定义触发器。那是可能的吗？或者，我们是否可以在回填进行时使用包含巨大延迟的触发器部署作业，然后在完成时使用正常触发器发布更新？

Answer 1

Dataflow 尚不支持自定义触发器或基于某些单独元数据的触发器。但是，您可以使用 Update 更改处理时间触发器的频率；只需更改 plusDelay() 构建器函数的值和 运行 与 --update 一样正常。