AfterWatermark.AfterWatermarkEarly (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.AfterWatermarkEarly<W extends BoundedWindow>

    • Method Detail

      • withLateFirings

        TriggerBuilder<W> withLateFirings(Trigger.OnceTrigger<W> lateTrigger)
        Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires after 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.