Apache Beam Getting Started - #2

main.2.java

public class Indexer {
    public static void main(String[] args) throws Exception {
        // ...

        p.apply(FileIO.match().filepattern(options.getInputFile()))
            .apply(FileIO.readMatches())
            .apply("ReadFile", ParDo.of(new ReadFileFn()))

        // ..
    }
}