Pinned Loading

1. GoogleCloudPlatform/dataflow-solution-guides GoogleCloudPlatform/dataflow-solution-guides Public

   The Dataflow Solution Guides offer full end-to-end deployment for the most common streaming solutions to run on Dataflow.

   HCL 31 15

2. fpinscala fpinscala Public

   Solution to the exercises of Functional Programming in Scala, from Mannig Publications

   Scala 11 1

3. scio-scala-beam-summit scio-scala-beam-summit Public

   This repository contains the template and the solution for the Beam Summit 2021 workshop

   Scala 4 1

4. beam-late-data beam-late-data Public

   A unit test for Apache Beam streaming, to check if your window would drop data, and how many times would the window be triggered

   Java 2 2

5. splittable-dofns-python splittable-dofns-python Public

   This repository contains the code samples used for the workshop "Splittable DoFns in Python" of the Beam Summit 2022

   Python 3 5

6. bigquery-dataflow-cdc-example bigquery-dataflow-cdc-example Public

   A Dataflow streaming pipeline written in Java, reading data from Pubsub and recovering the sessions from potentially unordered data, and upserting the session data into BigQuery with no duplicates

   Java