Apache Beam is a unified programming model for Batch and Streaming data processing.

Cloud Dataflow Google-provided templates for solving in-Cloud data tasks

Retail banking sample application showcasing Kubernetes and Google Cloud

Apache Flink Training Excercises

Example project using GitHub Maven Plugins

PubSubClient (PSC)

Building Big Data Pipelines with Apache Beam, published by Packt

Convenient Dataflow pipelines for transforming data between cloud data sources

Apache Beam Example 中国开源社区

Simple example of error handling per-element in Apache Beam.

Collection of utilities for working with BigQuery in Apache Beam

Cloud Dataflow pipeline that reads the file from Cloud Storage and processes and outputs in the memory store.

Common utilities Dataflow

BigQuery integration to Apache Flink's Table API

Cloud Storage using Spring Boot

Design patterns provide a reusable solution to commonly occurring software problems.

This is a project that aims to quickly show how you can build a custom IO transform in beam to ingest Tweets from Twitter and load them into BigQuery.