Practical Real-time Data Processing and Analytics

Running example

You need Java 7 or a later version and Maven to build the code. Let's get ready and run the tech world famous word count example with Apache Beam.

The preceding Maven command generates a Maven project that contains Apache Beam's WordCount example:

    $ mvnarchetype:generate \
          -DarchetypeRepository=https://repository.apache.org/content           /groups/snapshots \
          -DarchetypeGroupId=org.apache.beam \
          -DarchetypeArtifactId=beam-sdks-java-maven-archetypes-examples \
          -DarchetypeVersion=LATEST \
          -DgroupId=org.example \
          -DartifactId=word-count-beam \
          -Dversion="0.1" \
          -Dpackage=org.apache.beam.examples \
          -DinteractiveMode=false
  

This will create a folder named word-count-beam which contains the code:

$ cd word-count-beam/ $ ls pom.xml ...