Skip to content

Instantly share code, notes, and snippets.

@brachi-wernick

brachi-wernick/UsingSideInput.java

Created March 6, 2019 16:05
Show Gist options
  • Save brachi-wernick/c312852c2c534e8c44c30c4615600634 to your computer and use it in GitHub Desktop.
Save brachi-wernick/c312852c2c534e8c44c30c4615600634 to your computer and use it in GitHub Desktop.
Download ZIP
UsingSideInput
Raw
UsingSideInput.java
.apply(Window.into(FixedWindows.of(Duration.standardSeconds(1))))
.apply("extract-events", ParDo.of(new EventsRowFn(sideView)).withSideInputs(sideView));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment