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

Reply via email to