AfterWatermark.AfterWatermarkLate (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms.windowing

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.


Hai trovato utile questa pagina? Facci sapere cosa ne pensi:

Invia feedback per...

Hai bisogno di assistenza? Visita la nostra pagina di assistenza.