Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val data: PCollection[Type] = results
- .apply(
- Window
- .into[Type](FixedWindows.of(Duration.millis(2000)))
- .withAllowedLateness(Duration.millis(1000))
- .triggering(AfterPane.elementCountAtLeast(4)
- .accumulatingFiredPanes()
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement