ilacorda/apache-beam-go-tutorial

Apache Beam Golang SDK Sample Project

This repository demonstrates the usage of Apache Beam Golang SDK as part of a small use case whereby words from a file are counted by omitting duplicates.

Before you begin

Make sure you have a Go development environment ready. If you don't, you can follow the instructions in the Download and install page.

Running the pipeline

go run main.go

# To run the tests.
go test ./transformations -v

Using other runners

To keep this template small, it only includes the Direct Runner.

For a comparison of what each runner currently supports, look at the Beam Capability Matrix.

To add a new runner, visit the runner's page for instructions on how to include it.