You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by Sachin Mittal <sj...@gmail.com> on 2023/06/09 14:10:00 UTC

Can anyone tell me difference between these transformations

1.

Window.<KV<K, V>>into(FixedWindows.of(windowSize))
    .triggering(Never.ever())
    .withAllowedLateness(allowedLateness, Window.ClosingBehavior.FIRE_ALWAYS)
    .discardingFiredPanes()


2.

Window.<KV<K, V>>into(FixedWindows.of(windowSize))
    .triggering(Repeatedly.forever(AfterWatermark.pastEndOfWindow()))
    .withAllowedLateness(allowedLateness)
    .discardingFiredPanes()


If both are identical, which one should be preferred?

Thanks
Sachin