Online anomaly detection for data streams/ Real-time anomaly detection for time series data.

Faust dockerized application

RealTime StockStream is a streamlined, simulation system for processing live stock market data. It uses Apache Kafka for data input, Apache Spark for data handling, and Apache Cassandra for data storage, making it a powerful yet easy-to-use tool for financial data analysis

This code belongs to ACL conference paper entitled as "An Online Semantic-enhanced Dirichlet Model for Short Text Stream Clustering"

Hybrid Forest: A Concept Drift Aware Data Stream Mining Algorithm

A lightweight and polyglot stream-processing library, to be used as a data backplane-, message relay-, or pipeline-subsystem.

Udacity Data Streaming - Project Optimizing Public Transportation

Analyzes rocket league replays, allowing the user to write Streaming-SQL to find out information about the replay as it plays.

Automated deployment of an Apache Storm cluster in your Grid'5000 reserved nodes.

Final project for the course 'Architecture for Large Data Volumes', taught in the Bachelor's program in Data Science at ITAM

Metro is pipelines orchestrator platform for stream data.

Udacity Data Streaming project based on Apache Kafka

Usage of the UOB algorithm in the unbalanced static data streams processing - Academic Project

Paper IEEE ICPS 2025 - Arend/Schwung - "Online-adaptive data stream processing via cascaded and reverse adaptation"

Learn about Data Engineering ⛏️, Data Pipelines Building 🪈 ,Batch Processing 🥅and Data Streaming 🎏 with PostgreSQL, Docker, dbt , AirFlow ,Airbyte, Spark and Kafka

Automated deployment of an Apache Flink cluster in your Grid'5000 reserved nodes.

PyFlink data stream processing utilities 🐿

DataStream-SQLServer provides real-time data streaming from SQL Server using Zookeeper, Kafka, and Debezium. This repository contains the necessary configurations, Docker setups, and sample code to get you started.

Real-time data engineering pipeline for an American hiring platform