Skip to content

Instantly share code, notes, and snippets.

@imrenagi

imrenagi/late.java

Created January 10, 2019 01:16
Show Gist options
  • Save imrenagi/0b2c181e636d65585b00ede28d2b9214 to your computer and use it in GitHub Desktop.
Save imrenagi/0b2c181e636d65585b00ede28d2b9214 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
late.java
PCollection<String> items = ...;
PCollection<String> fixedWindowedItems = items.apply(
Window.<String>into(FixedWindows.of(Duration.standardMinutes(1)))
.withAllowedLateness(Duration.standardDays(2)));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment