Skip to content

Instantly share code, notes, and snippets.

@alexvanboxel

alexvanboxel/medium_beam_large

Last active March 31, 2017 17:45
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save alexvanboxel/0f672ac9165d320ccf04fec052235fd4 to your computer and use it in GitHub Desktop.
Save alexvanboxel/0f672ac9165d320ccf04fec052235fd4 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
medium_beam_large
.apply("SessionWindows for products", Window.<Event>into(Sessions.withGapDuration(Duration.standardDays(10)))
.triggering(Repeatedly.forever(AfterProcessingTime
.pastFirstElementInPane()
.plusDelayOf(Duration.standardSeconds(60))
).orFinally(AfterWatermark.pastEndOfWindow()))
.accumulatingFiredPanes()
.withAllowedLateness(Duration.ZERO)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment