ETL scripts for Bitcoin, Litecoin, Dash, Zcash, Doge, Bitcoin Cash. Available in Google BigQuery https://goo.gl/oY5BCQ

Clojure API for a more dynamic Google Dataflow

Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes

Export a whole BigQuery table to Google Datastore with Apache Beam/Google Dataflow

Solace connector for Apache Beam / Google Cloud Dataflow

Blockchain ETL Architecture

Stream Twitter Data into BigQuery with Cloud Dataprep

ETL scripts for EOS.

Tokenize Japanese text on BigQuery with Kuromoji in Apache Beam/Google Dataflow at scale

Metrics collection library for Google Dataflow

ETL scripts for Hedera Hashgraph

Playground for Google Python Libraries

Tutorials on Google Cloud Platform

Getting Started with Apache Beam: inverted index

Cookiecutter template for Google Cloud Dataflow Python projects

Dataflow pipeline for detecting anomalous transactions on the Ethereum and Bitcoin blockchains

Read files from s3 and create pcollection from it.

A go daemon that collects monitoring metrics from Google Dataflow workers and exposes them to Prometheus

Google Cloud native web analytics using Google Compute Engine, Cloud SQL Server, Cloud Dataflow, Google Kubernetes Engine and Google Deployment Manager

Another Dataflow Templates