Apache Beam + Kotlin examples

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));
    }
}