sanderploegsma · January 31, 2018 19:04
diff --git a/BeamExamples2.kt b/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 }
    }
 }
	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 }
	}
	}