Serverless multi-protocol + multi-destination event collection system.

Differentiable Programming Algorithms in Modern C++

Adapter for dbt that executes dbt pipelines on Apache Flink

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

Source code of a heavy hitter packet streaming application implemented with four stream processing systems: Flink, Spark Streaming, Storm and WindFlow.

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.

Open-source, Cloud-native Streams

Allow Streams applications to read / write to Cloudant database

Streaming data processing in Azure

Apama Connectivity Plugin for Apache Pulsar Messaging Framework.

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

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

Sentiment Analysis of Long-term of Social Data during the COVID-19 Pandemic

Advanced Web Technologies Project @ TUB

Learnings on ksqlDB

Código fuente: Análisis de Vuelos basado en trabajo de Valliappa Lakshmanan.