google-ai-edge/mediapipe
Cross-platform, customizable ML solutions for live and streaming media.
A star delta has been computed for 62,252 of 63,106 tracked repositories in this period, and only those can be ranked in it.
A repository missing here has not been measured far enough back yet. That does not mean it did not move.
Star counts measured between 07:52 and 16:49 (BKK).
Cross-platform, customizable ML solutions for live and streaming media.
A high-performance observability data pipeline.
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
Upserts, Deletes And Incremental Processing on Big Data.
🌊 Online machine learning in Python
The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
Python Stream Processing
Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
Distributed stream processing engine in Rust
A complete Sigma detection engineering toolkit: parser, linter, evaluator, correlation engine, conversion framework, streaming daemon, MCP and LSP servers :crab:
ultra low latency graph based stream processing framework
The Fastest Unified Streaming SQL Engine in a Single C++ Binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute real-time context from streams, logs, metrics, events, and CDC.
🦭 Distributed log streaming engine built from first principles
QuestDB is a high performance, open-source, time-series database
Python Streaming DataFrames for Kafka
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Kubernetes-native platform to run massively parallel data/streaming jobs
Open Source Phasor Data Concentrator
Unified real-time data engine
The serverless framework purpose-built for event streaming applications.
Framework for building Event-Driven Microservices
The database purpose-built for stream processing applications.
Zero-cost & Type-safe Reactive Extensions for Rust. Supports both high-performance single-threaded (Local) and thread-safe (Shared) contexts. WASM & Tokio ready.
Play any radios around the globe right from the terminal :zap:
Stream Processing and Complex Event Processing Engine
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
A Python stream processing engine modeled after Yahoo! Pipes
An Async SDR Runtime for Heterogeneous Architectures
Showing 30 of 32 repositories