GitHub topics: stream-processing-engine
infinyon/fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Language: Rust - Size: 34.6 MB - Last synced at: less than a minute ago - Pushed at: 7 days ago - Stars: 5,097 - Forks: 518
ArroyoSystems/arroyo
Distributed stream processing engine in Rust
Language: Rust - Size: 15.5 MB - Last synced at: about 11 hours ago - Pushed at: about 11 hours ago - Stars: 4,664 - Forks: 321
GridProtectionAlliance/openPDC
Open Source Phasor Data Concentrator
Language: C# - Size: 2.59 GB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 150 - Forks: 58
eventflux-io/engine
Rust-native, pattern-first stream processing engine (CEP): filters, joins, enrichment, windows—low latency on-prem & Kubernetes.
Language: Rust - Size: 2.72 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 3 - Forks: 1
velostreamai/velostream
Velostream is a high-performance streaming SQL engine built in Rust, designed for real-time analytics on financial and time-series data. It supports pluggable formats (JSON, Avro, Protobuf) and emphasizes low-latency processing, precision, and seamless integration with modern data pipelines
Language: Rust - Size: 17.8 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 4 - Forks: 1
GridProtectionAlliance/gsf
Grid Solutions Framework
Language: C# - Size: 249 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 168 - Forks: 72
liflab/beepbeep-3
An event stream processor anyone can use
Language: Java - Size: 40.9 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 27 - Forks: 16
panthers-labs-pvt-ltd/conduit
Conduit is a no-code, next-gen data ingestion platform that unifies pipelines across databases, files, and streams. With drag-and-drop workflows, real-time monitoring, and broad source support, Conduit makes data integration fast, scalable, and accessible to all teams.
Language: Java - Size: 21.5 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0
WallarooLabs/wally
Distributed Stream Processing
Language: Pony - Size: 268 MB - Last synced at: 6 months ago - Pushed at: over 4 years ago - Stars: 1,481 - Forks: 68
EuclidStellar/medplat-demo
The Unified Data Ingestion System is designed to handle both streaming and batch data ingestion with a modular architecture.
Language: Python - Size: 14.6 KB - Last synced at: 4 months ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0
lw-lin/streaming-readings
Streaming System 相关的论文读物
Size: 6.84 KB - Last synced at: 6 months ago - Pushed at: almost 4 years ago - Stars: 733 - Forks: 154
tsung-wei-huang/DtCraft
A High-performance Cluster Computing Engine
Language: C++ - Size: 45.3 MB - Last synced at: 8 months ago - Pushed at: over 6 years ago - Stars: 146 - Forks: 25
FCanfran/ATM-DP
Continuous Query Engine for the Detection of Anomalous ATM transactions
Language: Python - Size: 712 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0
nextorigin/godot2 Fork of nodejitsu/godot
A streaming real-time event processor based on Riemann written in Node.js -- Streams2/3 edition
Language: CoffeeScript - Size: 491 KB - Last synced at: 3 months ago - Pushed at: almost 9 years ago - Stars: 19 - Forks: 0
lucylow/l3gacy_fps
Anti-Cheat Detection for Game Streaming
Size: 2.93 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 3
sfischer13/docker-riko 📦
:whale: Docker image for riko
Language: Dockerfile - Size: 3.91 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 1
carldata/hydra
Stream processing engine with custom scripts
Language: Scala - Size: 108 KB - Last synced at: over 2 years ago - Pushed at: almost 8 years ago - Stars: 3 - Forks: 0
nextorigin/godot2-dash Fork of riemann/riemann-dash
An HTTP dashboard for Godot2.
Language: JavaScript - Size: 1.09 MB - Last synced at: about 2 months ago - Pushed at: almost 9 years ago - Stars: 16 - Forks: 1