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!
Requirements: Java 1.7+, Maven (tested on 3.3.9)
git clone https://github.com/ecesena/beam-starter
cd beam-starter
mvn clean package
- Based on instructions from https://github.com/apache/incubator-beam/tree/master/runners/flink
- Apache Beam: https://beam.incubator.apache.org
- Apache Flink: https://flink.apache.org
- Docker image with Apache Beam + Flink: https://github.com/ecesena/docker-beam-flink
- Blog: A quick demo of Apache Beam with Docker