WordCount quickstart for Java
This quickstart shows you how to set up a Java development environment and run an example pipeline written with the Apache Beam Java SDK, using a runner of your choice.
If you’re interested in contributing to the Apache Beam Java codebase, see the Contribution Guide.
On this page:
Set up your development environment
- Download and install the Java Development Kit (JDK) version 8, 11, or 17. Verify that the JAVA_HOME environment variable is set and points to your JDK installation.
- Download and install Apache Maven by following the installation guide for your operating system.
- Optional: If you want to convert your Maven project to Gradle, install Gradle.
Get the example code
Generate a Maven example project that builds against the latest Beam release:
Maven creates a new project in the word-count-beam directory.
Change into word-count-beam:
List the example pipelines:
- DebuggingWordCount.java (GitHub)
- MinimalWordCount.java (GitHub)
- WindowedWordCount.java (GitHub)
- WordCount.java (GitHub)
The example used in this tutorial, WordCount.java, defines a Beam pipeline that counts words from an input file (by default, a .txt file containing Shakespeare’s “King Lear”). To learn more about the examples, see the WordCount Example Walkthrough.
Optional: Convert from Maven to Gradle
The steps below explain how to convert the build from Maven to Gradle for the following runners:
- Direct runner
- Dataflow runner
The conversion process for other runners is similar. For additional guidance, see Migrating Builds From Apache Maven.
- In the directory with the pom.xml file, run the automated Maven-to-Gradle conversion:
- Open the generated build.gradle.kts file and make the following changes:
repositories, declare a repository for Confluent Kafka dependencies:
- At the end of the build script, add the following conditional dependency:
- At the end of the build script, add the following task:
- Build your project:
Get sample text
If you’re planning to use the DataflowRunner, you can skip this step. The runner will pull text directly from Google Cloud Storage.
- In the word-count-beam directory, create a file called sample.txt.
- Add some text to the file. For this example, use the text of Shakespeare’s King Lear.
Run a pipeline
A single Beam pipeline can run on multiple Beam runners. The DirectRunner is useful for getting started, because it runs on your machine and requires no specific setup. If you’re just trying out Beam and you’re not sure what to use, use the DirectRunner.
The general process for running a pipeline goes like this:
- Complete any runner-specific setup.
- Build your command line:
- Specify a runner with
--runner=<runner>(defaults to the DirectRunner).
- Add any runner-specific required options.
- Choose input files and an output location that are accessible to the runner. (For example, you can’t access a local file if you are running the pipeline on an external cluster.)
- Specify a runner with
- Run the command.
To run the WordCount pipeline:
Follow the setup steps for your runner:
The DirectRunner will work without additional setup.
Run the corresponding Maven or Gradle command below.
Run WordCount using Maven
For Unix shells:
mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \ -Dexec.args="--runner=DataflowRunner --project=<your-gcp-project> \ --region=<your-gcp-region> \ --gcpTempLocation=gs://<your-gcs-bucket>/tmp \ --inputFile=gs://apache-beam-samples/shakespeare/* --output=gs://<your-gcs-bucket>/counts" \ -Pdataflow-runner
For Windows PowerShell:
mvn compile exec:java -D exec.mainClass=org.apache.beam.examples.WordCount ` -D exec.args="--runner=DataflowRunner --project=<your-gcp-project> ` --region=<your-gcp-region> \ --gcpTempLocation=gs://<your-gcs-bucket>/tmp ` --inputFile=gs://apache-beam-samples/shakespeare/* --output=gs://<your-gcs-bucket>/counts" ` -P dataflow-runner
Run WordCount using Gradle
For Unix shells:
Inspect the results
After the pipeline has completed, you can view the output. There might be
multiple output files prefixed by
count. The number of output files is decided
by the runner, giving it the flexibility to do efficient, distributed execution.
- View the output files in a Unix shell:
- View the output content in a Unix shell:
... Think: 3 slower: 1 Having: 1 revives: 1 these: 33 wipe: 1 arrives: 1 concluded: 1 begins: 3 ...
- Learn more about the Beam SDK for Java and look through the Java SDK API reference.
- Walk through the WordCount examples in the WordCount Example Walkthrough.
- Take a self-paced tour through our Learning Resources.
- Dive in to some of our favorite Videos and Podcasts.
- Join the Beam users@ mailing list.
Please don’t hesitate to reach out if you encounter any issues!
Last updated on 2023/05/31
Have you found everything you were looking for?
Was it all useful and clear? Is there anything that you would like to change? Let us know!