/beam-starter

Get started with Apache Beam and Flink

Primary LanguageJavaApache License 2.0Apache-2.0

Apache Beam Starter

This is a starter repo for Apache Beam. You can read the blog post A quick demo of Apache Beam with Docker.

It currently contains a WordCount pipeline for the Apache Flink runner, and it's used in this Docker image with Apache Beam + Flink.

More interesting examples coming soon. In the meantime, this can be used as a starter repo to create new Beam pipelines, check out the pom.xml and change it as needed.

If you start a project forking this repo, I'd love to hear about it!

Build

Requirements: Java 1.7+, Maven (tested on 3.3.9)

git clone https://github.com/ecesena/beam-starter
cd beam-starter
mvn clean package

Open Source