java

Overview

This directory holds code to build an Apache Beam pipeline written in java.

Requirements

NOTE: installing gradle is not required

• Java version 11

Usage

Running Word Count

Run the following command to execute the pipeline on your local machine.

./gradlew run -Pargs="--source=src/main/resources/catsum.txt"

or

Assumes previously run gcloud auth application-default login

./gradlew run -Pargs="--source=gs://apache-beam-samples/shakespeare/*"

Show help

For help on command-line arguments, run:

./gradlew run -Pargs="-help=com.google.example.WordCountOptions"