Distributed stream processing engine in Rust
-
Updated
Jul 8, 2024 - Rust
Distributed stream processing engine in Rust
This project focuses on implementing and demonstrating how stream and buffer works along together in nodejs.
A lightweight and polyglot stream-processing library, to be used as a data backplane-, message relay-, or pipeline-subsystem.
Simulation framework focused in stream processing systems
This repo has various work I've done or assisted with in my capstone project for my Bachelors degree in Computer Engineering at Cal Poly Pomona.
RTEC is an Event Calculus implementation optimised for stream reasoning
Memphis.dev is a highly scalable and effortless data streaming platform
Final project for the course 'Architecture for Large Data Volumes', taught in the Bachelor's program in Data Science at ITAM
Real-Time Multimodal Emotion Classification System in E-Learning Context
Real-time Emotion Recognition using Physiological signals in e-Learning Here one can find the development of realtime emotion recognition using various physiological signals
Implementation/Tutorial of using Automated Machine Learning (AutoML) methods for static/batch and online/continual learning
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.
Dekaf is a visual user interface for Apache Pulsar 🛸
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.
OscillatorIMP ecosystem for the digital characterization of ultrastable oscillators and Software Defined Radio (SDR) frontend processing
Real-time data engineering pipeline for an American hiring platform
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
Flink Example
Hands on data streaming
Metro is pipelines orchestrator platform for stream data.
Add a description, image, and links to the data-stream-processing topic page so that developers can more easily learn about it.
To associate your repository with the data-stream-processing topic, visit your repo's landing page and select "manage topics."