Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- PCollection<KV<String, Integer>> scores = input
- .apply(Window.into(FixedWindows.of(Duration.standardMinutes(2)))
- .triggering(
- AtWatermark()
- .withEarlyFirings(AtPeriod(Duration.standardMinutes(1)))
- .withLateFirings(AtCount(1)))
- .accumulatingAndRetractingFiredPanes())
- .apply(Sum.integersPerKey())
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement