Distributed stream processing engine in Rust

• UpdatedNov 5, 2025
• Rust

Memphis.dev is a highly scalable and effortless data streaming platform

• UpdatedMay 27, 2024
• Go

Implementation/Tutorial of using Automated Machine Learning (AutoML) methods for static/batch and online/continual learning

• UpdatedMay 14, 2024
• Jupyter Notebook

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

• UpdatedMay 11, 2023
• Python

RTEC is an Event Calculus implementation optimised for stream reasoning

• UpdatedOct 21, 2025
• Prolog

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

• UpdatedMar 21, 2022
• Go

Faust dockerized application

• UpdatedDec 1, 2022
• Python

Rust based DuckDB Server with 1st class Postgres interface for BI Tools like Power BI and Tableau. Streaming interfaces like Web, Kafka, and FlightSQL/RPC.

• UpdatedOct 29, 2025
• HTML

OscillatorIMP ecosystem for the digital characterization of ultrastable oscillators and Software Defined Radio (SDR) frontend processing

• UpdatedSep 30, 2025

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

• UpdatedMar 5, 2023
• Java

This repository includes code for the AutoML-based IDS and adversarial attack defense case studies presented in the paper "Enabling AutoML for Zero-Touch Network Security: Use-Case Driven Analysis" published in IEEE Transactions on Network and Service Management.

• UpdatedMar 13, 2025
• Jupyter Notebook

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

• UpdatedFeb 18, 2025
• Python

Real-time Emotion Recognition using Physiological signals in e-Learning Here one can find the development of realtime emotion recognition using various physiological signals

• UpdatedMay 18, 2024
• Jupyter Notebook

Flink Example

• UpdatedNov 19, 2023
• Scala

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

• UpdatedApr 22, 2021
• Python

Realtime Data Processing and Search Engine Implementation.

• UpdatedAug 10, 2022
• Java

Apache Kafka for the Hybrid IoT

• UpdatedMar 21, 2019
• JavaScript

Real-time visual analytics for soccer matches, leveraging Apache Flink, Apache Kafka and the Elastic stack. Solution to DEBS 2013 Grand Challenge. Coursework in Systems and Architectures for Big Data 2016/2017.

• UpdatedJul 25, 2017
• Java

Hybrid Forest: A Concept Drift Aware Data Stream Mining Algorithm

• UpdatedJan 29, 2019
• Python

Real-time visual analytics application for link prediction and link detection in criminal networks. Research work accepted to the 5th IEEE International Conference on Future of Internet of Things and Cloud (FiCloud 2017).

• UpdatedJul 28, 2017
• Java