This repository contains the source code for my blog post "PubSub to BigQuery: How to Build a Data Pipeline Using Dataflow, Apache Beam, and Java"
This is a tutorial on creating a Dataflow pipeline that streams data from PubSub to BigQuery in Java.
You can find the full description of how to set the environment and run it in the post.