ilya-kozyrev/word-count-mini-beam

Demo project to show to dump pipeline representation in Apache Beam

Java

Minimal Word Count Example with Pipeline Representation

See this blog post that explains this code in detail.

Apache Beam project based on the minimal word count example, modified to show how to get the pipeline representation.

More general info about the word count examples in Apache Beam can be found in the documentation.

Running the code

Software requirements

Java 8 (Java 9 or above are not officially supported by Beam yet)
Maven 3.6.x

Running on your local machine (direct runner)

mvn compile exec:java \
        -Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
        -Pdirect-runner