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 43 18

2. scio-scala-beam-summit scio-scala-beam-summit Public

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

   Scala 5 1

3. 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 3 2

4. 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 2 5

5. 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

6. beam-college-2026 beam-college-2026 Public

   Apache Beam pipeline demonstrating a two-tiered state architecture for high-performance entity building and session reconstruction from out-of-order streaming events. Official demo for Beam College…

   Java