data-stream-processing 开源项目推荐（73 个）

ArroyoSystems /arroyo

用 Rust 编写的分布式流处理引擎

superstreamlabs /memphis

Memphis.dev 是一个高度可扩展且轻松易用的数据流平台

Western-OC2-Lab /AutoML-Implementation-for-Static-and-Dynamic-Data-Analytics

使用自动化机器学习（AutoML）方法进行静态/批量和在线/持续学习的实现/教程

Fengrui-Liu /StreamAD

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

aartikis /RTEC

RTEC is an Event Calculus implementation optimised for stream reasoning

boilingdata /boilstream

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.

inloco /kafka-elasticsearch-injector

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

marcosschroh /faust-docker-compose-example

Faust dockerized application

timeplus-io /vistral

Visual + Stream , a live stream data visualization lib, follows the Grammar of Graphics

oscimp /oscimpDigital

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

zmyzheng /TweetMap

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

Western-OC2-Lab /AutoML-and-Adversarial-Attack-Defense-for-Zero-Touch-Network-Security

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.

eventflux-io /eventflux

Rust-native, pattern-first stream processing engine (CEP): filters, joins, enrichment, windows—low latency on-prem & Kubernetes.

anqorithm /RealTime-StockStream

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

officialarijit /RECS

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

JayKumarr /OSDM

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

AhmetFurkanDEMIR /Flink-Example

Flink Example

ognis1205 /mutad

Realtime Data Processing and Search Engine Implementation.

braineering /socstream

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.

radinhamidi /Hybrid_Forest

Hybrid Forest: A Concept Drift Aware Data Stream Mining Algorithm