Skip to content

Instantly share code, notes, and snippets.

@sanderploegsma

sanderploegsma/BeamExamples2.kt

Last active January 31, 2018 19:04
Show Gist options
  • Save sanderploegsma/10e6180c00a189df5f4b4c583c2336e2 to your computer and use it in GitHub Desktop.
Save sanderploegsma/10e6180c00a189df5f4b4c583c2336e2 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
BeamExamples2.kt
class BeamExamples2 {
public fun process(input: PCollection<Person>): PCollection<String> {
return input.filter("Filter by age") { it.age >= 18 }
.map("Map to first name") { it.firstName }
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment