Distributed stream processing engine in Rust
-
Updated
Nov 12, 2026 - Rust
GeezerVisonThe World Wide Web, restored to 800 pixels of glory. |
| Home|About|Gaming cabinet|Archives|How it works|Starter sites |
GeezerVison is showing github.com — Build software better, together
#
data-stream-processingHere are 73 public repositories matching this topic...Language: All
Filter by language
Sort: Most stars
Sort options
Distributed stream processing engine in Rust
infrastructure rust data sql kafka stream-processing stream-processing-engine dev-tools data-stream-processing
Memphis.dev is a highly scalable and effortless data streaming platform
kubernetes golang data enrichment microservices schema-registry message-bus message-queue data-engineering data-pipeline message-broker data-streaming data-stream-processing messaging-queue
Implementation/Tutorial of using Automated Machine Learning (AutoML) methods for static/batch and online/continual learning
iot machine-learning deep-learning model-selection data-preprocessing feature-engineering hyperparameter-tuning concept-drift automl intrusion-detection-system automated-machine-learning data-streams python-examples data-stream-processing python-samples iot-data-analytics
Online anomaly detection for data streams/ Real-time anomaly detection for time series data.
python machine-learning streaming timeseries time-series outlier-detection online-learning incremental-learning anomaly-detection data-streams data-stream-processing real-time-detection
RTEC is an Event Calculus implementation optimised for stream reasoning
data-science cep prolog artificial-intelligence stream-processing logic-programming complex-event-processing multi-agent-systems data-stream-processing event-calculus stream-reasoning complex-event-recognition
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.
rust sql kafka analytics flight object-storage data-streams data-stream-processing duckdb data-stream-processing-framework ducklake
Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster
Faust dockerized application
Visual + Stream , a live stream data visualization lib, follows the Grammar of Graphics
OscillatorIMP ecosystem for the digital characterization of ultrastable oscillators and Software Defined Radio (SDR) frontend processing
ecosystem fpga sdr buildroot redpitaya digital-signal-processing radio-frequency software-defined-radio linux-driver data-stream-processing plutosdr digital-characterization
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
bootstrap docker kubernetes aws angular cloud kibana kafka spring-boot microservice sentiment-analysis flink elaticsearch data-stream-processing
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.
machine-learning deep-learning feature-selection cybersecurity hyperparameter-optimization ids feature-engineering network-automation hyperparameter-tuning concept-drift automl intrusion-detection-system automated-machine-learning data-streams adversarial-machine-learning python-examples data-stream-processing adversarial-attacks 6g zero-touch-network
Rust-native, pattern-first stream processing engine (CEP): filters, joins, enrichment, windows—low latency on-prem & Kubernetes.
infrastructure rust events data sql cep stream-processing complex-event-processing stream-processing-engine data-stream-processing
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
python docker kafka spark apache-spark docker-compose asynchronous bigdata realtime databases zookeeper stock-market spark-streaming stocks spark-master data-stream-processing cassendra apache-sparksql
Real-time Emotion Recognition using Physiological signals in e-Learning Here one can find the development of realtime emotion recognition using various physiological signals
e-learning affective-computing real-time-processing data-stream-processing emotion-classification real-time-emotion-classification
This code belongs to ACL conference paper entitled as "An Online Semantic-enhanced Dirichlet Model for Short Text Stream Clustering"
text-mining data-stream stochastic-process non-parametric dirichlet-process dirichlet-process-mixtures text-clustering text-stream data-stream-processing data-stream-mining
Flink Example
docker scala kafka ubuntu apache data-engineering apache-flink flink kafka-streams debezium flink-stream-processing data-stream-processing flink-streaming flink-sql debeziumkafkaconnector debezium-connector debezium-client scala2
Realtime Data Processing and Search Engine Implementation.
java docker aws elasticsearch cloud typescript kibana kafka spring-boot storm microservice reactjs nextjs material-ui data-stream-processing data-stream-mining
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.
elasticsearch real-time kibana elasticstack soccer apache-flink apache-kafka visual-analytics big-data-analytics data-stream-processing
Hybrid Forest: A Concept Drift Aware Data Stream Mining Algorithm
data-science machine-learning data-mining regression artificial-intelligence classification data-stream-processing
Add this topic to your repoTo associate your repository with the data-stream-processing topic, visit your repo's landing page and select "manage topics." |
| You are visitor 01402503 — GeezerVison does not store the pages you look up. Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required. |