🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Serverless multi-protocol + multi-destination event collection system.
Adapter for dbt that executes dbt pipelines on Apache Flink
📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.
This repo assists in building streaming analytics platform using RisingWave and dbt, empowering your real-time data insights.
Real-time ETL pipeline for financial data (kafka, pyspark) .
Extends the standard cumulocity administration with dialog to add analytics builder extensions
Self-Supervised Adaptive and Interpretable Anomaly Detection with Dynamic Operating Limits
This repo provides a template for developing Cumulocity Streaming Analytics assets such as Blocks and EPL Apps, with a dev container for opening in Visual Studio Code
Source code of a heavy hitter packet streaming application implemented with four stream processing systems: Flink, Spark Streaming, Storm and WindFlow.
An end‑to‑end real-time analytics & anomaly detection with PySpark Structured Streaming on user activity logs from Kafka
Built a Large Scale Distributed Data Processing system for Streaming Analytics using Hadoop Ecosystem (Apache Spark and HDFS), in Cloud for real-time spatial analytics.
Apama Connectivity Plugin for Apache Pulsar Messaging Framework.
Streaming data processing in Azure
Performance Analysis of Apache Kafka and Apache Flink Streaming using VMs on the LRZ Cloud.
A real-life end-to-end cloud sub-system scenario
Building application analytics streaming for delivering data-enriched visualizations in a real-time dashboard
Real-time Coinbase market data streaming pipeline with visualizations. Much appreciation to DataTalks.Club Data Engineering Zoom Camp: https://github.com/DataTalksClub/data-engineering-zoomcamp
📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.
Allow Streams applications to read / write to Cloudant database