AfterWatermark.AfterWatermarkLate (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Interface AfterWatermark.AfterWatermarkLate<W extends BoundedWindow>

    • Method Detail

      • withEarlyFirings

        TriggerBuilder<W> withEarlyFirings(Trigger.OnceTrigger<W> earlyTrigger)
        Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires before the watermark has passed the end of the window.

Оцените, насколько информация на этой странице была вам полезна:

Оставить отзыв о...

Текущей странице
Dataflow: Stream & Batch Processing
Нужна помощь? Обратитесь в службу поддержки.