Hi all,

I was wondering how to use AfterSynchronizedProcessingTime trigger. for
processing time triggers there's the
AfterProcessingTime.pastFirstElementInPane() API but I've noticed that
AfterSynchronizedProcessingTime constructor is only called from a a
continuation trigger.
I wonder if someone could explain how should pipeline authors use this
trigger, and maybe a general explanation about processing time triggers
since (as far as I could find) most of existing
documentations/presentations/talks are focused on watermark-based triggers.

Thanks,
Amit

Reply via email to