Details
-
Bug
-
Status: Resolved
-
P4
-
Resolution: Fixed
-
None
Description
* <pre>{@code * PCollection<String> windowed_items = items.apply( * Window.<String>into(FixedWindows.of(Duration.standardMinutes(1)) * .triggering( * .triggering( * AfterWatermark.pastEndOfWindow() * .withEarlyFirings(AfterProcessingTime * .pastFirstElementInPane().plusDelayOf(Duration.standardMinutes(1)))) * .withAllowedLateness(Duration.ZERO)); * }</pre>
Attachments
Issue Links
- links to