stateful-processing

Here are 4 public repositories matching this topic...

iht / beam-college-2026

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 2026 talk.

java demo streaming cache data-engineering apache-beam sessionization stateful-processing beam-college out-of-order-events

Updated Sep 25, 2026
Java

rbublyk-crypto / regulatory-data-layer-demo

Star

Portfolio demo of a stateful regulatory short-position data layer

python data-engineering market-data financial-data event-driven-architecture apify capital-markets regulatory-data apify-actor stateful-processing

Updated Sep 25, 2026
Python

isinghabhishek / streaming_pipeline

Star

A production-grade real-time streaming pipeline ingesting multi-source events (REST, IoT, WebSocket) into Apache Kafka (Avro & Schema Registry), statefully processing streams via Apache Flink with exactly-once Delta Lake storage, dbt transformations, and Grafana dashboards.