Skip to content

Instantly share code, notes, and snippets.

@brachi-wernick

brachi-wernick/UseSideInput.java

Created March 6, 2019 16:05
Show Gist options
  • Save brachi-wernick/8c999fb93d74046f18950d480ab53de1 to your computer and use it in GitHub Desktop.
Save brachi-wernick/8c999fb93d74046f18950d480ab53de1 to your computer and use it in GitHub Desktop.
Download ZIP
USing side input
Raw
UseSideInput.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