Skip to content

Instantly share code, notes, and snippets.

@stanislavkozlovski

stanislavkozlovski/example.java

Last active September 3, 2025 18:07
Show Gist options
  • Save stanislavkozlovski/eb1cb74169a08f7e770e79abd2dde488 to your computer and use it in GitHub Desktop.
Save stanislavkozlovski/eb1cb74169a08f7e770e79abd2dde488 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
example.java
builder.stream("page-views")
.groupByKey()
.filter((page, pageView) -> !isBot(pageView))
.windowedBy(Duration.ofMinutes(1))
.count()
.toStream()
.to("traffic-alerts");
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment