Skip to content

Instantly share code, notes, and snippets.

@sanderploegsma

sanderploegsma/BeamExamples.java

Last active October 9, 2019 13:14
Show Gist options
  • Save sanderploegsma/f9b9f7c6d79b2a83e508d94005a82af3 to your computer and use it in GitHub Desktop.
Save sanderploegsma/f9b9f7c6d79b2a83e508d94005a82af3 to your computer and use it in GitHub Desktop.
Download ZIP
Apache Beam + Kotlin examples
Raw
BeamExamples.java
class BeamExamples {
public PCollection<Person> filterByAge(PCollection<Person> input, int age) {
return input.apply("Filter by age", Filter.by(p -> p.getAge() >= age));
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment